org.apache.kudu.flume.sink

Class KuduSinkConfigurationConstants

java.lang.Object

org.apache.kudu.flume.sink.KuduSinkConfigurationConstants

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class KuduSinkConfigurationConstants
extends Object

Constants used for configuration of KuduSink

Field Summary

Fields

Modifier and Type	Field and Description
static String	BATCH_SIZE Maximum number of events the sink should take from the channel per transaction, if available.
static String	IGNORE_DUPLICATE_ROWS Whether to ignore errors indicating that we attempted to insert duplicate rows into Kudu.
static String	MASTER_ADDRESSES Comma-separated list of "host:port" pairs of the masters (port optional).
static String	PRODUCER The fully qualified class name of the Kudu event producer the sink should use.
static String	PRODUCER_PREFIX Configuration to pass to the Kudu event producer.
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 Summary

Constructors

Constructor and Description
KuduSinkConfigurationConstants()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MASTER_ADDRESSES

public static final String MASTER_ADDRESSES

Comma-separated list of "host:port" pairs of the masters (port optional).

See Also:

Constant Field Values

TABLE_NAME

public static final String TABLE_NAME

The name of the table in Kudu to write to.

See Also:

Constant Field Values

PRODUCER

public static final String PRODUCER

The fully qualified class name of the Kudu event producer the sink should use.

See Also:

Constant Field Values

PRODUCER_PREFIX

public static final String PRODUCER_PREFIX

Configuration to pass to the Kudu event producer.

See Also:

Constant Field Values

BATCH_SIZE

public static final String BATCH_SIZE

Maximum number of events the sink should take from the channel per transaction, if available.

See Also:

Constant Field Values

TIMEOUT_MILLIS

public static final String TIMEOUT_MILLIS

Timeout period for Kudu operations, in milliseconds.

See Also:

Constant Field Values

IGNORE_DUPLICATE_ROWS

public static final String IGNORE_DUPLICATE_ROWS

Whether to ignore errors indicating that we attempted to insert duplicate rows into Kudu.

See Also:

Constant Field Values

Constructor Detail

KuduSinkConfigurationConstants

public KuduSinkConfigurationConstants()