org.apache.flume.sink.elasticsearch
Class ElasticSearchSinkConstants

java.lang.Object
  org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants

public class ElasticSearchSinkConstants
extends Object

Field Summary

static String	BATCH_SIZE Maximum number of events the sink should take from the channel per transaction, if available.
static String	CLUSTER_NAME Name of the ElasticSearch cluster to connect to
static String	DEFAULT_CLUSTER_NAME
static String	DEFAULT_INDEX_NAME
static String	DEFAULT_INDEX_TYPE
static int	DEFAULT_PORT DEFAULTS USED BY THE SINK
static int	DEFAULT_TTL
static String	HOSTNAMES Comma separated list of hostname:port, if the port is not present the default port '9300' will be used
static String	INDEX_NAME The name to index the document to, defaults to 'flume'
static String	INDEX_TYPE The type to index the document to, defaults to 'log'
static String	SERIALIZER The fully qualified class name of the serializer the sink should use.
static String	SERIALIZER_PREFIX Configuration to pass to the serializer.
static String	TTL TTL in days, when set will cause the expired documents to be deleted automatically, if not set documents will never be automatically deleted

Constructor Summary

ElasticSearchSinkConstants()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

HOSTNAMES

public static final String HOSTNAMES

Comma separated list of hostname:port, if the port is not present the default port '9300' will be used

Example:

  127.0.0.1:92001,127.0.0.2:9300
 

See Also:

Constant Field Values

INDEX_NAME

public static final String INDEX_NAME

The name to index the document to, defaults to 'flume'

The current date in the format 'yyyy-MM-dd' will be appended to this name, for example 'foo' will result in a daily index of 'foo-yyyy-MM-dd'

See Also:

Constant Field Values

INDEX_TYPE

public static final String INDEX_TYPE

The type to index the document to, defaults to 'log'

See Also:

Constant Field Values

CLUSTER_NAME

public static final String CLUSTER_NAME

Name of the ElasticSearch cluster to connect to

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. Defaults to 100

See Also:

Constant Field Values

TTL

public static final String TTL

TTL in days, when set will cause the expired documents to be deleted automatically, if not set documents will never be automatically deleted

See Also:

Constant Field Values

SERIALIZER

public static final String SERIALIZER

The fully qualified class name of the serializer the sink should use.

See Also:

Constant Field Values

SERIALIZER_PREFIX

public static final String SERIALIZER_PREFIX

Configuration to pass to the serializer.

See Also:

Constant Field Values

DEFAULT_PORT

public static final int DEFAULT_PORT

DEFAULTS USED BY THE SINK

See Also:

Constant Field Values

DEFAULT_TTL

public static final int DEFAULT_TTL

See Also:

Constant Field Values

DEFAULT_INDEX_NAME

public static final String DEFAULT_INDEX_NAME

See Also:

Constant Field Values

DEFAULT_INDEX_TYPE

public static final String DEFAULT_INDEX_TYPE

See Also:

Constant Field Values

DEFAULT_CLUSTER_NAME

public static final String DEFAULT_CLUSTER_NAME

See Also:

Constant Field Values

Constructor Detail

ElasticSearchSinkConstants

public ElasticSearchSinkConstants()