| 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.