@InterfaceAudience.Public @InterfaceStability.Evolving public class KuduSinkConfigurationConstants extends Object
Modifier and Type | Field and Description |
---|---|
static String |
BATCH_SIZE
Maximum number of events that the sink should take from the channel per
transaction.
|
static String |
IGNORE_DUPLICATE_ROWS
Whether to ignore duplicate primary key errors caused by inserts.
|
static String |
MASTER_ADDRESSES
Comma-separated list of "host:port" Kudu master addresses.
|
static String |
PRODUCER
The fully qualified class name of the KuduOperationsProducer class that the
sink should use.
|
static String |
PRODUCER_PREFIX
Prefix for configuration parameters that are passed to the
KuduOperationsProducer.
|
static String |
TABLE_NAME
The name of the table in Kudu to write to.
|
static String |
TIMEOUT_MILLIS
Timeout period for Kudu operations, in milliseconds.
|
Constructor and Description |
---|
KuduSinkConfigurationConstants() |
public static final String MASTER_ADDRESSES
public static final String TABLE_NAME
public static final String PRODUCER
public static final String PRODUCER_PREFIX
public static final String BATCH_SIZE
public static final String TIMEOUT_MILLIS
public static final String IGNORE_DUPLICATE_ROWS
Copyright © 2018 The Apache Software Foundation. All rights reserved.