Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_OPERATION_TIMEOUT_MS |
30000L |
public static final long |
DEFAULT_SOCKET_READ_TIMEOUT_MS |
10000L |
public static final long |
NO_TIMESTAMP |
-1L |
public static final int |
SLEEP_TIME |
500 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_OPERATION |
"upsert" |
public static final String |
OPERATION_PROP |
"operation" |
public static final String |
SCHEMA_LITERAL_HEADER |
"flume.avro.schema.literal" |
public static final String |
SCHEMA_PROP |
"schemaPath" |
public static final String |
SCHEMA_URL_HEADER |
"flume.avro.schema.url" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BATCH_SIZE |
"batchSize" |
public static final String |
IGNORE_DUPLICATE_ROWS |
"ignoreDuplicateRows" |
public static final String |
MASTER_ADDRESSES |
"masterAddresses" |
public static final String |
PRODUCER |
"producer" |
public static final String |
PRODUCER_PREFIX |
"producer." |
public static final String |
TABLE_NAME |
"tableName" |
public static final String |
TIMEOUT_MILLIS |
"timeoutMillis" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_ENCODING |
"utf-8" |
public static final String |
DEFAULT_OPERATION |
"upsert" |
public static final boolean |
DEFAULT_SKIP_BAD_COLUMN_VALUE |
false |
public static final boolean |
DEFAULT_SKIP_MISSING_COLUMN |
false |
public static final boolean |
DEFAULT_WARN_UNMATCHED_ROWS |
true |
public static final String |
ENCODING_PROP |
"encoding" |
public static final String |
OPERATION_PROP |
"operation" |
public static final String |
PATTERN_PROP |
"pattern" |
public static final String |
SKIP_BAD_COLUMN_VALUE_PROP |
"skipBadColumnValue" |
public static final String |
SKIP_MISSING_COLUMN_PROP |
"skipMissingColumn" |
public static final String |
WARN_UNMATCHED_ROWS_PROP |
"skipUnmatchedRows" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY_COLUMN_DEFAULT |
"key" |
public static final String |
KEY_COLUMN_PROP |
"keyColumn" |
public static final String |
OPERATION_DEFAULT |
"upsert" |
public static final String |
OPERATION_PROP |
"operation" |
public static final String |
PAYLOAD_COLUMN_DEFAULT |
"payload" |
public static final String |
PAYLOAD_COLUMN_PROP |
"payloadColumn" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PAYLOAD_COLUMN_DEFAULT |
"payload" |
public static final String |
PAYLOAD_COLUMN_PROP |
"payloadColumn" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ADMIN_OPERATION_TIMEOUT_MS_KEY |
"kudu.admin.operation.timeout.ms" |
public static final String |
MASTER_ADDRESSES_DEFAULT |
"127.0.0.1" |
public static final String |
MASTER_ADDRESSES_KEY |
"kudu.master.addresses" |
public static final int |
NUM_REPLICAS_DEFAULT |
3 |
public static final String |
NUM_REPLICAS_KEY |
"kudu.num.replicas" |
public static final long |
OPERATION_TIMEOUT_MS_DEFAULT |
30000L |
public static final String |
OPERATION_TIMEOUT_MS_KEY |
"kudu.operation.timeout.ms" |
public static final long |
SOCKET_READ_TIMEOUT_MS_DEFAULT |
10000L |
public static final String |
SOCKET_READ_TIMEOUT_MS_KEY |
"kudu.socket.read.timeout.ms" |
Copyright © 2017 The Apache Software Foundation. All rights reserved.