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 long |
NO_TIMESTAMP |
-1L |
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 |
KERBEROS_KEYTAB |
"kerberosKeytab" |
public static final String |
KERBEROS_PRINCIPAL |
"kerberosPrincipal" |
public static final String |
MASTER_ADDRESSES |
"masterAddresses" |
public static final String |
PRODUCER |
"producer" |
public static final String |
PRODUCER_PREFIX |
"producer." |
public static final String |
PROXY_USER |
"proxyUser" |
public static final String |
TABLE_NAME |
"tableName" |
public static final String |
TIMEOUT_MILLIS |
"timeoutMillis" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BAD_COLUMN_VALUE_POLICY_PROP |
"badColumnValuePolicy" |
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 |
MISSING_COLUMN_POLICY_PROP |
"missingColumnPolicy" |
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 |
UNMATCHED_ROW_POLICY_PROP |
"unmatchedRowPolicy" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
COLUMN_CLIENT |
"client" |
public static final int |
COLUMN_CLIENT_IDX |
5 |
public static final String |
COLUMN_KEY_ONE |
"key1" |
public static final int |
COLUMN_KEY_ONE_IDX |
0 |
public static final String |
COLUMN_KEY_TWO |
"key2" |
public static final int |
COLUMN_KEY_TWO_IDX |
1 |
public static final String |
COLUMN_PREV_ONE |
"prev1" |
public static final int |
COLUMN_PREV_ONE_IDX |
2 |
public static final String |
COLUMN_PREV_TWO |
"prev2" |
public static final int |
COLUMN_PREV_TWO_IDX |
3 |
public static final String |
COLUMN_ROW_ID |
"row_id" |
public static final int |
COLUMN_ROW_ID_IDX |
4 |
public static final String |
COLUMN_UPDATE_COUNT |
"update_count" |
public static final int |
COLUMN_UPDATE_COUNT_IDX |
6 |
public static final String |
DEFAULT_HEADS_TABLE_NAME |
"IntegrationTestBigLinkedListHeads" |
public static final String |
DEFAULT_TABLE_NAME |
"IntegrationTestBigLinkedList" |
public static final String |
HEADS_TABLE_NAME_KEY |
"IntegrationTestBigLinkedList.heads_table" |
public static final String |
TABLE_NAME_KEY |
"IntegrationTestBigLinkedList.table" |
Copyright © 2018 The Apache Software Foundation. All rights reserved.