Constant Field Values

Contents

• org.apache.*

org.apache.*

org.apache.flume.Constants

Modifier and Type	Constant Field	Value
public static final String	SYSPROP_CALLED_FROM_SERVICE	"flume.called.from.service"

org.apache.flume.agent.embedded.EmbeddedAgentConfiguration

Modifier and Type	Constant Field	Value
public static final String	CHANNEL	"channel"
public static final String	SEPERATOR	"."
public static final String	SINK_PROCESSOR	"processor"
public static final String	SINKS	"sinks"
public static final String	SOURCE	"source"

org.apache.flume.api.RpcClientConfigurationConstants

Modifier and Type	Constant Field	Value
public static final String	CONFIG_BACKOFF	"backoff"
public static final String	CONFIG_BATCH_SIZE	"batch-size"
public static final String	CONFIG_CLIENT_TYPE	"client.type"
public static final String	CONFIG_COMPRESSION_LEVEL	"compression-level"
public static final String	CONFIG_COMPRESSION_TYPE	"compression-type"
public static final String	CONFIG_CONNECT_TIMEOUT	"connect-timeout"
public static final String	CONFIG_CONNECTION_POOL_SIZE	"maxConnections"
public static final String	CONFIG_EXCLUDE_CIPHER_SUITES	"exclude-cipher-suites"
public static final String	CONFIG_EXCLUDE_PROTOCOLS	"exclude-protocols"
public static final String	CONFIG_HOST_SELECTOR	"host-selector"
public static final String	CONFIG_HOSTS	"hosts"
public static final String	CONFIG_HOSTS_PREFIX	"hosts."
public static final String	CONFIG_INCLUDE_CIPHER_SUITES	"include-cipher-suites"
public static final String	CONFIG_INCLUDE_PROTOCOLS	"include-protocols"
public static final String	CONFIG_MAX_ATTEMPTS	"max-attempts"
public static final String	CONFIG_MAX_BACKOFF	"maxBackoff"
public static final String	CONFIG_REQUEST_TIMEOUT	"request-timeout"
public static final String	CONFIG_SSL	"ssl"
public static final String	CONFIG_TRUST_ALL_CERTS	"trust-all-certs"
public static final String	CONFIG_TRUSTSTORE	"truststore"
public static final String	CONFIG_TRUSTSTORE_PASSWORD	"truststore-password"
public static final String	CONFIG_TRUSTSTORE_TYPE	"truststore-type"
public static final String	DEFAULT_BACKOFF	"false"
public static final int	DEFAULT_COMPRESSION_LEVEL	6
public static final int	DEFAULT_CONNECTION_POOL_SIZE	5
public static final String	HOST_SELECTOR_RANDOM	"RANDOM"
public static final String	HOST_SELECTOR_ROUND_ROBIN	"ROUND_ROBIN"
public static final String	KERBEROS_KEY	"kerberos"
public static final String	MAX_IO_WORKERS	"maxIoWorkers"

org.apache.flume.api.SecureThriftRpcClient.UgiSaslClientTransport

Modifier and Type	Constant Field	Value
protected static final int	DEFAULT_MAX_LENGTH	2147483647
protected static final int	MECHANISM_NAME_BYTES	1
protected static final int	PAYLOAD_LENGTH_BYTES	4
protected static final int	STATUS_BYTES	1

org.apache.flume.api.ThriftRpcClient

Modifier and Type	Constant Field	Value
public static final String	BINARY_PROTOCOL	"binary"
public static final String	COMPACT_PROTOCOL	"compact"
public static final String	CONFIG_PROTOCOL	"protocol"

org.apache.flume.channel.MultiplexingChannelSelector

Modifier and Type	Constant Field	Value
public static final String	CONFIG_DEFAULT_CHANNEL	"default"
public static final String	CONFIG_MULTIPLEX_HEADER_NAME	"header"
public static final String	CONFIG_PREFIX_MAPPING	"mapping."
public static final String	CONFIG_PREFIX_OPTIONAL	"optional"
public static final String	DEFAULT_MULTIPLEX_HEADER	"flume.selector.header"

org.apache.flume.channel.ReplicatingChannelSelector

Modifier and Type	Constant Field	Value
public static final String	CONFIG_OPTIONAL	"optional"

org.apache.flume.channel.SpillableMemoryChannel

Modifier and Type	Constant Field	Value
public static final String	AVG_EVENT_SIZE	"avgEventSize"
public static final String	BYTE_CAPACITY	"byteCapacity"
public static final String	BYTE_CAPACITY_BUFFER_PERCENTAGE	"byteCapacityBufferPercentage"
public static final String	CAPACITY	"capacity"
public static final int	defaultMemoryCapacity	10000
public static final int	defaultOverflowCapacity	100000000
public static final int	defaultOverflowDeactivationThreshold	5
public static final int	defaultOverflowTimeout	3
public static final String	KEEP_ALIVE	"keep-alive"
public static final String	MEMORY_CAPACITY	"memoryCapacity"
public static final String	OVERFLOW_CAPACITY	"overflowCapacity"
public static final String	OVERFLOW_DEACTIVATION_THRESHOLD	"overflowDeactivationThreshold"
public static final String	OVERFLOW_TIMEOUT	"overflowTimeout"

org.apache.flume.channel.file.FileChannelConfiguration

Modifier and Type	Constant Field	Value
public static final String	BACKUP_CHECKPOINT_DIR	"backupCheckpointDir"
public static final String	CAPACITY	"capacity"
public static final String	CHECKPOINT_DIR	"checkpointDir"
public static final String	CHECKPOINT_INTERVAL	"checkpointInterval"
public static final String	CHKPT_ONCLOSE	"checkpointOnClose"
public static final String	COMPRESS_BACKUP_CHECKPOINT	"compressBackupCheckpoint"
public static final String	DATA_DIRS	"dataDirs"
public static final int	DEFAULT_CAPACITY	1000000
public static final long	DEFAULT_CHECKPOINT_INTERVAL	30000L
public static final boolean	DEFAULT_COMPRESS_BACKUP_CHECKPOINT	false
public static final int	DEFAULT_FSYNC_INTERVAL	5
public static final boolean	DEFAULT_FSYNC_PRE_TXN	true
public static final int	DEFAULT_KEEP_ALIVE	3
public static final long	DEFAULT_MAX_FILE_SIZE	1623195647L
public static final long	DEFAULT_MINIMUM_REQUIRED_SPACE	524288000L
public static final int	DEFAULT_TRANSACTION_CAPACITY	10000
public static final boolean	DEFAULT_USE_DUAL_CHECKPOINTS	false
public static final boolean	DEFAULT_USE_FAST_REPLAY	false
public static final boolean	DEFAULT_USE_LOG_REPLAY_V1	false
public static final long	FLOOR_MINIMUM_REQUIRED_SPACE	1048576L
public static final String	FSYNC_INTERVAL	"fsyncInterval"
public static final String	FSYNC_PER_TXN	"fsyncPerTransaction"
public static final String	KEEP_ALIVE	"keep-alive"
public static final String	MAX_FILE_SIZE	"maxFileSize"
public static final String	MINIMUM_REQUIRED_SPACE	"minimumRequiredSpace"
public static final String	TRANSACTION_CAPACITY	"transactionCapacity"
public static final String	USE_DUAL_CHECKPOINTS	"useDualCheckpoints"
public static final String	USE_FAST_REPLAY	"use-fast-replay"
public static final String	USE_LOG_REPLAY_V1	"use-log-replay-v1"

org.apache.flume.channel.file.Log

Modifier and Type	Constant Field	Value
public static final String	FILE_LOCK	"in_use.lock"
public static final String	PREFIX	"log-"
public static final String	QUEUE_SET	"queueset"

org.apache.flume.channel.file.LogFile

Modifier and Type	Constant Field	Value
public static final byte	OP_EOF	-128
public static final byte	OP_NOOP	0
public static final byte	OP_RECORD	127

org.apache.flume.channel.file.Serialization

Modifier and Type	Constant Field	Value
public static final String	METADATA_FILENAME	".meta"
public static final String	METADATA_TMP_FILENAME	".tmp"
public static final String	OLD_METADATA_FILENAME	".meta.old"

org.apache.flume.channel.file.encryption.EncryptionConfiguration

Modifier and Type	Constant Field	Value
public static final String	ACTIVE_KEY	"activeKey"
public static final String	CIPHER_PROVIDER	"cipherProvider"
public static final String	ENCRYPTION_PREFIX	"encryption"
public static final String	JCE_FILE_KEY_PASSWORD_FILE	"passwordFile"
public static final String	JCE_FILE_KEY_STORE_FILE	"keyStoreFile"
public static final String	JCE_FILE_KEY_STORE_PASSWORD_FILE	"keyStorePasswordFile"
public static final String	JCE_FILE_KEYS	"keys"
public static final String	KEY_PROVIDER	"keyProvider"

org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog

Modifier and Type	Constant Field	Value
public static final int	COUNT_FIELD_NUMBER	2
public static final int	LOGFILEID_FIELD_NUMBER	1

org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint

Modifier and Type	Constant Field	Value
public static final int	ACTIVELOGS_FIELD_NUMBER	5
public static final int	QUEUEHEAD_FIELD_NUMBER	4
public static final int	QUEUESIZE_FIELD_NUMBER	3
public static final int	VERSION_FIELD_NUMBER	1
public static final int	WRITEORDERID_FIELD_NUMBER	2

org.apache.flume.channel.file.proto.ProtosFactory.Commit

Modifier and Type	Constant Field	Value
public static final int	TYPE_FIELD_NUMBER	1

org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent

Modifier and Type	Constant Field	Value
public static final int	BODY_FIELD_NUMBER	2
public static final int	HEADERS_FIELD_NUMBER	1

org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader

Modifier and Type	Constant Field	Value
public static final int	KEY_FIELD_NUMBER	1
public static final int	VALUE_FIELD_NUMBER	2

org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption

Modifier and Type	Constant Field	Value
public static final int	CIPHERPROVIDER_FIELD_NUMBER	1
public static final int	KEYALIAS_FIELD_NUMBER	2
public static final int	PARAMETERS_FIELD_NUMBER	3

org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData

Modifier and Type	Constant Field	Value
public static final int	BACKUPCHECKPOINTPOSITION_FIELD_NUMBER	6
public static final int	BACKUPCHECKPOINTWRITEORDERID_FIELD_NUMBER	7
public static final int	CHECKPOINTPOSITION_FIELD_NUMBER	3
public static final int	CHECKPOINTWRITEORDERID_FIELD_NUMBER	4
public static final int	ENCRYPTION_FIELD_NUMBER	5
public static final int	LOGFILEID_FIELD_NUMBER	2
public static final int	VERSION_FIELD_NUMBER	1

org.apache.flume.channel.file.proto.ProtosFactory.Put

Modifier and Type	Constant Field	Value
public static final int	CHECKSUM_FIELD_NUMBER	2
public static final int	EVENT_FIELD_NUMBER	1

org.apache.flume.channel.file.proto.ProtosFactory.Take

Modifier and Type	Constant Field	Value
public static final int	FILEID_FIELD_NUMBER	1
public static final int	OFFSET_FIELD_NUMBER	2

org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader

Modifier and Type	Constant Field	Value
public static final int	TRANSACTIONID_FIELD_NUMBER	2
public static final int	TYPE_FIELD_NUMBER	1
public static final int	WRITEORDERID_FIELD_NUMBER	3

org.apache.flume.channel.jdbc.ConfigurationConstants

Modifier and Type	Constant Field	Value
public static final String	CONFIG_CREATE_FK	"create.foreignkey"
public static final String	CONFIG_CREATE_INDEX	"create.index"
public static final String	CONFIG_CREATE_SCHEMA	"create.schema"
public static final String	CONFIG_DATABASE_TYPE	"db.type"
public static final String	CONFIG_JDBC_DRIVER_CLASS	"driver.class"
public static final String	CONFIG_JDBC_PROPS_FILE	"connection.properties.file"
public static final String	CONFIG_JDBC_SYSPROP_PREFIX	"sysprop."
public static final String	CONFIG_MAX_CAPACITY	"maximum.capacity"
public static final String	CONFIG_MAX_CONNECTIONS	"maximum.connections"
public static final String	CONFIG_PASSWORD	"db.password"
public static final String	CONFIG_TX_ISOLATION_LEVEL	"transaction.isolation"
public static final String	CONFIG_URL	"driver.url"
public static final String	CONFIG_USERNAME	"db.username"
public static final String	OLD_CONFIG_CREATE_FK	"org.apache.flume.channel.jdbc.create.foreignkey"
public static final String	OLD_CONFIG_CREATE_INDEX	"org.apache.flume.channel.jdbc.create.index"
public static final String	OLD_CONFIG_CREATE_SCHEMA	"org.apache.flume.channel.jdbc.create.schema"
public static final String	OLD_CONFIG_DATABASE_TYPE	"org.apache.flume.channel.jdbc.db.type"
public static final String	OLD_CONFIG_JDBC_DRIVER_CLASS	"org.apache.flume.channel.jdbc.driver.class"
public static final String	OLD_CONFIG_JDBC_PROPS_FILE	"org.apache.flume.channel.jdbc.connection.properties.file"
public static final String	OLD_CONFIG_JDBC_SYSPROP_PREFIX	"org.apache.flume.channel.jdbc.sysprop."
public static final String	OLD_CONFIG_MAX_CAPACITY	"org.apache.flume.channel.jdbc.maximum.capacity"
public static final String	OLD_CONFIG_MAX_CONNECTIONS	"org.apache.flume.channel.jdbc.maximum.connections"
public static final String	OLD_CONFIG_PASSWORD	"org.apache.flume.channel.jdbc.db.password"
public static final String	OLD_CONFIG_TX_ISOLATION_LEVEL	"org.apache.flume.channel.jdbc.transaction.isolation"
public static final String	OLD_CONFIG_URL	"org.apache.flume.channel.jdbc.driver.url"
public static final String	OLD_CONFIG_USERNAME	"org.apache.flume.channel.jdbc.db.username"
public static final String	PREFIX	"org.apache.flume.channel.jdbc."

org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

Modifier and Type	Constant Field	Value
public static final String	COLUMN_LOOKUP_QUERY	"SELECT COLUMNNAME from SYS.SYSCOLUMNS where REFERENCEID = (SELECT TABLEID FROM SYS.SYSTABLES WHERE TABLENAME = ? AND SCHEMAID = (SELECT SCHEMAID FROM SYS.SYSSCHEMAS WHERE SCHEMANAME = ? ))"
public static final String	QUERY_CHANNEL_SIZE	"SELECT COUNT(*) FROM FLUME.FL_EVENT"
public static final String	QUERY_CREATE_INDEX_FLE_CHANNEL	"CREATE INDEX FLUME.IDX_FLE_CHANNEL ON FLUME.FL_EVENT (FLE_CHANNEL)"
public static final String	QUERY_CREATE_INDEX_FLH_EVENT	"CREATE INDEX FLUME.IDX_FLH_EVENT ON FLUME.FL_HEADER (FLH_EVENT)"
public static final String	QUERY_CREATE_INDEX_FLN_HEADER	"CREATE INDEX FLUME.IDX_FLN_HEADER ON FLUME.FL_NMSPILL (FLN_HEADER)"
public static final String	QUERY_CREATE_INDEX_FLP_EVENT	"CREATE INDEX FLUME.IDX_FLP_EVENT ON FLUME.FL_PLSPILL (FLP_EVENT)"
public static final String	QUERY_CREATE_INDEX_FLV_HEADER	"CREATE INDEX FLUME.IDX_FLV_HEADER ON FLUME.FL_VLSPILL (FLV_HEADER)"
public static final String	QUERY_CREATE_SCHEMA_FLUME	"CREATE SCHEMA FLUME"
public static final String	QUERY_CREATE_TABLE_FL_PLSPILL_FMT	"CREATE TABLE FLUME.FL_PLSPILL ( FLP_EVENT BIGINT, FLP_SPILL BLOB{0})"
public static final String	STMT_DELETE_EVENT_BASE	"DELETE FROM FLUME.FL_EVENT WHERE FLE_ID = ?"
public static final String	STMT_DELETE_EVENT_SPILL	"DELETE FROM FLUME.FL_PLSPILL WHERE FLP_EVENT = ?"
public static final String	STMT_DELETE_HEADER_BASE	"DELETE FROM FLUME.FL_HEADER WHERE FLH_EVENT = ?"
public static final String	STMT_DELETE_HEADER_NAME_SPILL	"DELETE FROM FLUME.FL_NMSPILL WHERE FLN_HEADER = ?"
public static final String	STMT_DELETE_HEADER_VALUE_SPILL	"DELETE FROM FLUME.FL_VLSPILL WHERE FLV_HEADER = ?"
public static final String	STMT_FETCH_HEADER_BASE	"SELECT FLH_ID, FLH_NAME, FLH_VALUE, FLH_NMSPILL, FLH_VLSPILL FROM FLUME.FL_HEADER WHERE FLH_EVENT = ?"
public static final String	STMT_FETCH_HEADER_NAME_SPILL	"SELECT FLN_SPILL FROM FLUME.FL_NMSPILL WHERE FLN_HEADER = ?"
public static final String	STMT_FETCH_HEADER_VALUE_SPILL	"SELECT FLV_SPILL FROM FLUME.FL_VLSPILL WHERE FLV_HEADER = ?"
public static final String	STMT_FETCH_PAYLOAD_BASE	"SELECT FLE_ID, FLE_PAYLOAD, FLE_SPILL FROM FLUME.FL_EVENT WHERE FLE_ID = (SELECT MIN(FLE_ID) FROM FLUME.FL_EVENT WHERE FLE_CHANNEL = ?)"
public static final String	STMT_FETCH_PAYLOAD_SPILL	"SELECT FLP_SPILL FROM FLUME.FL_PLSPILL WHERE FLP_EVENT = ?"
public static final String	STMT_INSERT_EVENT_BASE	"INSERT INTO FLUME.FL_EVENT (FLE_PAYLOAD, FLE_CHANNEL, FLE_SPILL) VALUES ( ?, ?, ?)"
public static final String	STMT_INSERT_EVENT_SPILL	"INSERT INTO FLUME.FL_PLSPILL (FLP_EVENT, FLP_SPILL) VALUES ( ?, ?)"
public static final String	STMT_INSERT_HEADER_BASE	"INSERT INTO FLUME.FL_HEADER (FLH_EVENT, FLH_NAME, FLH_VALUE, FLH_NMSPILL, FLH_VLSPILL) VALUES ( ?, ?, ?, ?, ?)"
public static final String	STMT_INSERT_HEADER_NAME_SPILL	"INSERT INTO FLUME.FL_NMSPILL (FLN_HEADER, FLN_SPILL) VALUES ( ?, ?)"
public static final String	STMT_INSERT_HEADER_VALUE_SPILL	"INSERT INTO FLUME.FL_VLSPILL (FLV_HEADER, FLV_SPILL) VALUES ( ?, ?)"

org.apache.flume.channel.kafka.KafkaChannelConfiguration

Modifier and Type	Constant Field	Value
public static final String	AUTO_COMMIT_ENABLED	"auto.commit.enable"
public static final String	BOOTSTRAP_SERVERS_CONFIG	"kafka.bootstrap.servers"
public static final String	BROKER_LIST_FLUME_KEY	"brokerList"
public static final String	BROKER_LIST_KEY	"metadata.broker.list"
public static final String	CONSUMER_TIMEOUT	"consumer.timeout.ms"
public static final String	DEFAULT_ACKS	"all"
public static final String	DEFAULT_AUTO_OFFSET_RESET	"earliest"
public static final String	DEFAULT_GROUP_ID	"flume"
public static final String	DEFAULT_KEY_DESERIALIZER	"org.apache.kafka.common.serialization.StringDeserializer"
public static final String	DEFAULT_KEY_SERIALIZER	"org.apache.kafka.common.serialization.StringSerializer"
public static final boolean	DEFAULT_MIGRATE_ZOOKEEPER_OFFSETS	true
public static final boolean	DEFAULT_PARSE_AS_FLUME_EVENT	true
public static final long	DEFAULT_POLL_TIMEOUT	500L
public static final boolean	DEFAULT_READ_SMALLEST_OFFSET	false
public static final String	DEFAULT_TIMEOUT	"100"
public static final String	DEFAULT_TOPIC	"flume-channel"
public static final String	DEFAULT_VALUE_DESERIAIZER	"org.apache.kafka.common.serialization.ByteArrayDeserializer"
public static final String	DEFAULT_VALUE_SERIAIZER	"org.apache.kafka.common.serialization.ByteArraySerializer"
public static final String	GROUP_ID_FLUME	"groupId"
public static final String	KAFKA_CONSUMER_PREFIX	"kafka.consumer."
public static final String	KAFKA_PREFIX	"kafka."
public static final String	KAFKA_PRODUCER_PREFIX	"kafka.producer."
public static final String	KEY_HEADER	"key"
public static final String	MIGRATE_ZOOKEEPER_OFFSETS	"migrateZookeeperOffsets"
public static final String	PARSE_AS_FLUME_EVENT	"parseAsFlumeEvent"
public static final String	PARTITION_HEADER_NAME	"partitionIdHeader"
public static final String	POLL_TIMEOUT	"kafka.pollTimeout"
public static final String	READ_SMALLEST_OFFSET	"readSmallestOffset"
public static final String	REQUIRED_ACKS_KEY	"request.required.acks"
public static final String	STATIC_PARTITION_CONF	"defaultPartitionId"
public static final String	TIMEOUT	"timeout"
public static final String	TOPIC_CONFIG	"kafka.topic"
public static final String	ZOOKEEPER_CONNECT	"zookeeper.connect"
public static final String	ZOOKEEPER_CONNECT_FLUME_KEY	"zookeeperConnect"

org.apache.flume.conf.BasicConfigurationConstants

Modifier and Type	Constant Field	Value
public static final String	CONFIG_CHANNEL	"channel"
public static final String	CONFIG_CHANNELS	"channels"
public static final String	CONFIG_CHANNELS_PREFIX	"channels."
public static final String	CONFIG_CONFIG	"config"
public static final String	CONFIG_CONFIGFILTERS	"configfilters"
public static final String	CONFIG_CONFIGFILTERS_PREFIX	"configfilters."
public static final String	CONFIG_SINK_PROCESSOR_PREFIX	"processor."
public static final String	CONFIG_SINKGROUPS	"sinkgroups"
public static final String	CONFIG_SINKGROUPS_PREFIX	"sinkgroups."
public static final String	CONFIG_SINKS	"sinks"
public static final String	CONFIG_SINKS_PREFIX	"sinks."
public static final String	CONFIG_SOURCE_CHANNELSELECTOR_PREFIX	"selector."
public static final String	CONFIG_SOURCES	"sources"
public static final String	CONFIG_SOURCES_PREFIX	"sources."
public static final String	CONFIG_TYPE	"type"

org.apache.flume.conf.FlumeConfiguration

Modifier and Type	Constant Field	Value
public static final String	INDENTSTEP	" "

org.apache.flume.conf.LogPrivacyUtil

Modifier and Type	Constant Field	Value
public static final String	LOG_PRINTCONFIG_PROP	"org.apache.flume.log.printconfig"
public static final String	LOG_RAWDATA_PROP	"org.apache.flume.log.rawdata"

org.apache.flume.formatter.output.BucketPath

Modifier and Type	Constant Field	Value
public static final String	TAG_REGEX	"%(\\w|%)|%\\{([\\w\\.-]+)\\}|%\\[(\\w+)\\]"

org.apache.flume.formatter.output.PathManager

Modifier and Type	Constant Field	Value
public static final String	CTX_PREFIX	"pathManager."

org.apache.flume.instrumentation.GangliaServer

Modifier and Type	Constant Field	Value
public static final int	BUFFER_SIZE	1500
public final String	CONF_HOSTS	"hosts"
public final String	CONF_ISGANGLIA3	"isGanglia3"
public final String	CONF_POLL_FREQUENCY	"pollFrequency"
public static final int	DEFAULT_DMAX	0
public final int	DEFAULT_POLL_FREQUENCY	60
public static final int	DEFAULT_SLOPE	3
public static final int	DEFAULT_TMAX	60
public static final String	DEFAULT_UNITS	""
public static final String	GANGLIA_DOUBLE_TYPE	"double"

org.apache.flume.interceptor.RegexFilteringInterceptor.Constants

Modifier and Type	Constant Field	Value
public static final boolean	DEFAULT_EXCLUDE_EVENTS	false
public static final String	DEFAULT_REGEX	".*"
public static final String	EXCLUDE_EVENTS	"excludeEvents"
public static final String	REGEX	"regex"

org.apache.flume.interceptor.StaticInterceptor.Constants

Modifier and Type	Constant Field	Value
public static final String	KEY	"key"
public static final String	KEY_DEFAULT	"key"
public static final String	PRESERVE	"preserveExisting"
public static final boolean	PRESERVE_DEFAULT	true
public static final String	VALUE	"value"
public static final String	VALUE_DEFAULT	"value"

org.apache.flume.interceptor.TimestampInterceptor.Constants

Modifier and Type	Constant Field	Value
public static final String	CONFIG_HEADER_NAME	"headerName"
public static final String	CONFIG_PRESERVE	"preserveExisting"
public static final String	DEFAULT_HEADER_NAME	"timestamp"
public static final boolean	DEFAULT_PRESERVE	false

org.apache.flume.node.Application

Modifier and Type	Constant Field	Value
public static final String	CONF_MONITOR_CLASS	"flume.monitoring.type"
public static final String	CONF_MONITOR_PREFIX	"flume.monitoring."

org.apache.flume.serialization.AvroEventDeserializer

Modifier and Type	Constant Field	Value
public static final String	AVRO_SCHEMA_HEADER_HASH	"flume.avro.schema.hash"
public static final String	AVRO_SCHEMA_HEADER_LITERAL	"flume.avro.schema.literal"
public static final String	CONFIG_SCHEMA_TYPE_KEY	"schemaType"

org.apache.flume.serialization.AvroEventSerializerConfigurationConstants

Modifier and Type	Constant Field	Value
public static final String	COMPRESSION_CODEC	"compressionCodec"
public static final String	DEFAULT_COMPRESSION_CODEC	"null"
public static final int	DEFAULT_SYNC_INTERVAL_BYTES	2048000
public static final String	STATIC_SCHEMA_URL	"schemaURL"
public static final String	SYNC_INTERVAL_BYTES	"syncIntervalBytes"

org.apache.flume.serialization.EventSerializer

Modifier and Type	Constant Field	Value
public static final String	CTX_PREFIX	"serializer."

org.apache.flume.serialization.LineDeserializer

Modifier and Type	Constant Field	Value
public static final String	CHARSET_DFLT	"UTF-8"
public static final int	MAXLINE_DFLT	2048
public static final String	MAXLINE_KEY	"maxLineLength"
public static final String	OUT_CHARSET_KEY	"outputCharset"

org.apache.flume.serialization.ResettableFileInputStream

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_BUF_SIZE	16384
public static final int	MIN_BUF_SIZE	8

org.apache.flume.shared.kafka.test.KafkaPartitionTestUtil

Modifier and Type	Constant Field	Value
public static final String	PARTITION_HEADER	"partition-header"

org.apache.flume.sink.LoadBalancingSinkProcessor

Modifier and Type	Constant Field	Value
public static final String	CONFIG_BACKOFF	"backoff"
public static final String	CONFIG_SELECTOR	"selector"
public static final String	CONFIG_SELECTOR_PREFIX	"selector."
public static final String	SELECTOR_NAME_RANDOM	"RANDOM"
public static final String	SELECTOR_NAME_RANDOM_BACKOFF	"RANDOM_BACKOFF"
public static final String	SELECTOR_NAME_ROUND_ROBIN	"ROUND_ROBIN"
public static final String	SELECTOR_NAME_ROUND_ROBIN_BACKOFF	"ROUND_ROBIN_BACKOFF"

org.apache.flume.sink.LoggerSink

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_BYTE_DUMP	16
public static final String	MAX_BYTES_DUMP_KEY	"maxBytesToLog"

org.apache.flume.sink.hbase2.HBase2SinkConfigurationConstants

Modifier and Type	Constant Field	Value
public static final String	CONFIG_BATCHSIZE	"batchSize"
public static final String	CONFIG_COALESCE_INCREMENTS	"coalesceIncrements"
public static final String	CONFIG_COLUMN_FAMILY	"columnFamily"
public static final String	CONFIG_ENABLE_WAL	"enableWal"
public static final String	CONFIG_KEYTAB	"kerberosKeytab"
public static final String	CONFIG_MAX_CONSECUTIVE_FAILS	"maxConsecutiveFails"
public static final String	CONFIG_PRINCIPAL	"kerberosPrincipal"
public static final String	CONFIG_SERIALIZER	"serializer"
public static final String	CONFIG_SERIALIZER_PREFIX	"serializer."
public static final String	CONFIG_TABLE	"table"
public static final String	CONFIG_TIMEOUT	"timeout"
public static final boolean	DEFAULT_ENABLE_WAL	true
public static final int	DEFAULT_MAX_CONSECUTIVE_FAILS	10
public static final long	DEFAULT_TIMEOUT	60000L
public static final String	DEFAULT_ZK_ZNODE_PARENT	"/hbase"
public static final String	ZK_QUORUM	"zookeeperQuorum"
public static final String	ZK_ZNODE_PARENT	"znodeParent"

org.apache.flume.sink.hbase2.RegexHBase2EventSerializer

Modifier and Type	Constant Field	Value
public static final String	CHARSET_CONFIG	"charset"
public static final String	CHARSET_DEFAULT	"UTF-8"
public static final String	COL_NAME_CONFIG	"colNames"
public static final String	COLUMN_NAME_DEFAULT	"payload"
public static final String	DEPOSIT_HEADERS_CONFIG	"depositHeaders"
public static final boolean	DEPOSIT_HEADERS_DEFAULT	false
public static final String	IGNORE_CASE_CONFIG	"regexIgnoreCase"
public static final boolean	IGNORE_CASE_DEFAULT	false
public static final String	REGEX_CONFIG	"regex"
public static final String	REGEX_DEFAULT	"(.*)"
public static final String	ROW_KEY_INDEX_CONFIG	"rowKeyIndex"
public static final String	ROW_KEY_NAME	"ROW_KEY"

org.apache.flume.sink.hdfs.AvroEventSerializer

Modifier and Type	Constant Field	Value
public static final String	AVRO_SCHEMA_LITERAL_HEADER	"flume.avro.schema.literal"
public static final String	AVRO_SCHEMA_URL_HEADER	"flume.avro.schema.url"

org.apache.flume.sink.hdfs.HDFSEventSink

Modifier and Type	Constant Field	Value
public static final String	IN_USE_SUFFIX_PARAM_NAME	"hdfs.inUseSuffix"

org.apache.flume.sink.hive.Config

Modifier and Type	Constant Field	Value
public static final String	BATCH_SIZE	"batchSize"
public static final String	CALL_TIMEOUT	"callTimeout"
public static final String	HEART_BEAT_INTERVAL	"heartBeatInterval"
public static final String	HIVE_DATABASE	"hive.database"
public static final String	HIVE_METASTORE	"hive.metastore"
public static final String	HIVE_PARTITION	"hive.partition"
public static final String	HIVE_TABLE	"hive.table"
public static final String	HIVE_TXNS_PER_BATCH_ASK	"hive.txnsPerBatchAsk"
public static final String	HOUR	"hour"
public static final String	IDLE_TIMEOUT	"idleTimeout"
public static final String	MAX_OPEN_CONNECTIONS	"maxOpenConnections"
public static final String	MINUTE	"minute"
public static final String	ROUND	"round"
public static final String	ROUND_UNIT	"roundUnit"
public static final String	ROUND_VALUE	"roundValue"
public static final String	SECOND	"second"
public static final String	SERIALIZER	"serializer"
public static final String	TIME_ZONE	"timeZone"
public static final String	USE_LOCAL_TIME_STAMP	"useLocalTimeStamp"

org.apache.flume.sink.hive.HiveDelimitedTextSerializer

Modifier and Type	Constant Field	Value
public static final String	ALIAS	"DELIMITED"
public static final String	defaultDelimiter	","
public static final String	SERIALIZER_DELIMITER	"serializer.delimiter"
public static final String	SERIALIZER_FIELDNAMES	"serializer.fieldnames"
public static final String	SERIALIZER_SERDE_SEPARATOR	"serializer.serdeSeparator"

org.apache.flume.sink.hive.HiveJsonSerializer

Modifier and Type	Constant Field	Value
public static final String	ALIAS	"JSON"

org.apache.flume.sink.kafka.KafkaSinkConstants

Modifier and Type	Constant Field	Value
public static final String	ALLOW_TOPIC_OVERRIDE_HEADER	"allowTopicOverride"
public static final String	AVRO_EVENT	"useFlumeEventFormat"
public static final String	BATCH_SIZE	"flumeBatchSize"
public static final String	BOOTSTRAP_SERVERS_CONFIG	"kafka.bootstrap.servers"
public static final String	BROKER_LIST_FLUME_KEY	"brokerList"
public static final String	DEFAULT_ACKS	"1"
public static final boolean	DEFAULT_ALLOW_TOPIC_OVERRIDE_HEADER	true
public static final boolean	DEFAULT_AVRO_EVENT	false
public static final int	DEFAULT_BATCH_SIZE	100
public static final String	DEFAULT_KEY_SERIALIZER	"org.apache.kafka.common.serialization.StringSerializer"
public static final String	DEFAULT_TOPIC	"default-flume-topic"
public static final String	DEFAULT_TOPIC_OVERRIDE_HEADER	"topic"
public static final String	DEFAULT_VALUE_SERIAIZER	"org.apache.kafka.common.serialization.ByteArraySerializer"
public static final String	KAFKA_PREFIX	"kafka."
public static final String	KAFKA_PRODUCER_PREFIX	"kafka.producer."
public static final String	KEY_HEADER	"key"
public static final String	KEY_SERIALIZER_KEY	"key.serializer.class"
public static final String	MESSAGE_SERIALIZER_KEY	"serializer.class"
public static final String	OLD_BATCH_SIZE	"batchSize"
public static final String	PARTITION_HEADER_NAME	"partitionIdHeader"
public static final String	REQUIRED_ACKS_FLUME_KEY	"requiredAcks"
public static final String	STATIC_PARTITION_CONF	"defaultPartitionId"
public static final String	TOPIC_CONFIG	"kafka.topic"
public static final String	TOPIC_OVERRIDE_HEADER	"topicHeader"

org.apache.flume.sink.kite.DatasetSinkConstants

Modifier and Type	Constant Field	Value
public static final String	AUTH_KEYTAB	"auth.kerberosKeytab"
public static final String	AUTH_PRINCIPAL	"auth.kerberosPrincipal"
public static final String	AUTH_PROXY_USER	"auth.proxyUser"
public static final String	AVRO_ENTITY_PARSER	"avro"
public static final String	AVRO_SCHEMA_LITERAL_HEADER	"flume.avro.schema.literal"
public static final String	AVRO_SCHEMA_URL_HEADER	"flume.avro.schema.url"
public static final String	CONFIG_ENTITY_PARSER	"kite.entityParser"
public static final String	CONFIG_FAILURE_POLICY	"kite.failurePolicy"
public static final String	CONFIG_FLUSHABLE_COMMIT_ON_BATCH	"kite.flushable.commiteOnBatch"
public static final String	CONFIG_KITE_BATCH_SIZE	"kite.batchSize"
public static final String	CONFIG_KITE_DATASET_NAME	"kite.dataset.name"
public static final String	CONFIG_KITE_DATASET_NAMESPACE	"kite.dataset.namespace"
public static final String	CONFIG_KITE_DATASET_URI	"kite.dataset.uri"
public static final String	CONFIG_KITE_ERROR_DATASET_URI	"kite.error.dataset.uri"
public static final String	CONFIG_KITE_REPO_URI	"kite.repo.uri"
public static final String	CONFIG_KITE_ROLL_INTERVAL	"kite.rollInterval"
public static final String	CONFIG_SYNCABLE_SYNC_ON_BATCH	"kite.syncable.syncOnBatch"
public static final String	DEFAULT_ENTITY_PARSER	"avro"
public static final String	DEFAULT_FAILURE_POLICY	"retry"
public static final String	DEFAULT_NAMESPACE	"default"
public static final String	RETRY_FAILURE_POLICY	"retry"
public static final String	SAVE_FAILURE_POLICY	"save"

org.apache.flume.sink.solr.morphline.BlobDeserializer

Modifier and Type	Constant Field	Value
public static final int	MAX_BLOB_LENGTH_DEFAULT	100000000
public static final String	MAX_BLOB_LENGTH_KEY	"maxBlobLength"

org.apache.flume.sink.solr.morphline.BlobHandler

Modifier and Type	Constant Field	Value
public static final int	MAX_BLOB_LENGTH_DEFAULT	100000000
public static final String	MAX_BLOB_LENGTH_KEY	"maxBlobLength"

org.apache.flume.sink.solr.morphline.MorphlineHandlerImpl

Modifier and Type	Constant Field	Value
public static final String	MORPHLINE_FILE_PARAM	"morphlineFile"
public static final String	MORPHLINE_ID_PARAM	"morphlineId"
public static final String	MORPHLINE_VARIABLE_PARAM	"morphlineVariable"

org.apache.flume.sink.solr.morphline.MorphlineSink

Modifier and Type	Constant Field	Value
public static final String	BATCH_DURATION_MILLIS	"batchDurationMillis"
public static final String	BATCH_SIZE	"batchSize"
public static final String	HANDLER_CLASS	"handlerClass"

org.apache.flume.sink.solr.morphline.UUIDInterceptor

Modifier and Type	Constant Field	Value
public static final String	HEADER_NAME	"headerName"
public static final String	PREFIX_NAME	"prefix"
public static final String	PRESERVE_EXISTING_NAME	"preserveExisting"

org.apache.flume.source.ExecSourceConfigurationConstants

Modifier and Type	Constant Field	Value
public static final String	CHARSET	"charset"
public static final String	CONFIG_BATCH_SIZE	"batchSize"
public static final String	CONFIG_BATCH_TIME_OUT	"batchTimeout"
public static final String	CONFIG_LOG_STDERR	"logStdErr"
public static final String	CONFIG_RESTART	"restart"
public static final String	CONFIG_RESTART_THROTTLE	"restartThrottle"
public static final String	CONFIG_SHELL	"shell"
public static final int	DEFAULT_BATCH_SIZE	20
public static final long	DEFAULT_BATCH_TIME_OUT	3000L
public static final String	DEFAULT_CHARSET	"UTF-8"
public static final boolean	DEFAULT_LOG_STDERR	false
public static final boolean	DEFAULT_RESTART	false
public static final long	DEFAULT_RESTART_THROTTLE	10000L

org.apache.flume.source.NetcatSourceConfigurationConstants

Modifier and Type	Constant Field	Value
public static final String	CONFIG_ACKEVENT	"ack-every-event"
public static final String	CONFIG_HOSTNAME	"bind"
public static final String	CONFIG_MAX_LINE_LENGTH	"max-line-length"
public static final String	CONFIG_PORT	"port"
public static final String	CONFIG_SOURCE_ENCODING	"encoding"
public static final String	DEFAULT_ENCODING	"utf-8"
public static final int	DEFAULT_MAX_LINE_LENGTH	512

org.apache.flume.source.PollableSourceConstants

Modifier and Type	Constant Field	Value
public static final String	BACKOFF_SLEEP_INCREMENT	"backoffSleepIncrement"
public static final long	DEFAULT_BACKOFF_SLEEP_INCREMENT	1000L
public static final long	DEFAULT_MAX_BACKOFF_SLEEP	5000L
public static final String	MAX_BACKOFF_SLEEP	"maxBackoffSleep"

org.apache.flume.source.SpoolDirectorySourceConfigurationConstants

Modifier and Type	Constant Field	Value
public static final String	BASENAME_HEADER	"basenameHeader"
public static final String	BASENAME_HEADER_KEY	"basenameHeaderKey"
public static final String	BATCH_SIZE	"batchSize"
public static final String	BUFFER_MAX_LINE_LENGTH	"bufferMaxLineLength"
public static final String	BUFFER_MAX_LINES	"bufferMaxLines"
public static final String	CONSUME_ORDER	"consumeOrder"
public static final String	DECODE_ERROR_POLICY	"decodeErrorPolicy"
public static final boolean	DEFAULT_BASENAME_HEADER	false
public static final String	DEFAULT_BASENAME_HEADER_KEY	"basename"
public static final int	DEFAULT_BATCH_SIZE	100
public static final int	DEFAULT_BUFFER_MAX_LINE_LENGTH	5000
public static final int	DEFAULT_BUFFER_MAX_LINES	100
public static final String	DEFAULT_DELETE_POLICY	"never"
public static final String	DEFAULT_DESERIALIZER	"LINE"
public static final boolean	DEFAULT_FILE_HEADER	false
public static final String	DEFAULT_FILENAME_HEADER_KEY	"file"
public static final String	DEFAULT_IGNORE_PAT	"^$"
public static final String	DEFAULT_INCLUDE_PAT	"^.*$"
public static final String	DEFAULT_INPUT_CHARSET	"UTF-8"
public static final int	DEFAULT_POLL_DELAY	500
public static final boolean	DEFAULT_RECURSIVE_DIRECTORY_SEARCH	false
public static final String	DEFAULT_SPOOLED_FILE_SUFFIX	".COMPLETED"
public static final String	DEFAULT_TRACKER_DIR	".flumespool"
public static final String	DEFAULT_TRACKING_POLICY	"rename"
public static final String	DELETE_POLICY	"deletePolicy"
public static final String	DESERIALIZER	"deserializer"
public static final String	FILENAME_HEADER	"fileHeader"
public static final String	FILENAME_HEADER_KEY	"fileHeaderKey"
public static final String	IGNORE_PAT	"ignorePattern"
public static final String	INCLUDE_PAT	"includePattern"
public static final String	INPUT_CHARSET	"inputCharset"
public static final String	MAX_BACKOFF	"maxBackoff"
public static final String	POLL_DELAY	"pollDelay"
public static final String	RECURSIVE_DIRECTORY_SEARCH	"recursiveDirectorySearch"
public static final String	SPOOL_DIRECTORY	"spoolDir"
public static final String	SPOOLED_FILE_SUFFIX	"fileSuffix"
public static final String	TRACKER_DIR	"trackerDir"
public static final String	TRACKING_POLICY	"trackingPolicy"

org.apache.flume.source.SyslogSourceConfigurationConstants

Modifier and Type	Constant Field	Value
public static final String	CONFIG_BATCHSIZE	"batchSize"
public static final String	CONFIG_CHARSET	"charset.default"
public static final String	CONFIG_CLIENT_HOSTNAME_HEADER	"clientHostnameHeader"
public static final String	CONFIG_CLIENT_IP_HEADER	"clientIPHeader"
public static final String	CONFIG_DATEFORMAT	"dateFormat"
public static final String	CONFIG_EVENTSIZE	"eventSize"
public static final String	CONFIG_FORMAT_PREFIX	"format."
public static final String	CONFIG_HOST	"host"
public static final String	CONFIG_KEEP_FIELDS	"keepFields"
public static final String	CONFIG_KEEP_FIELDS_HOSTNAME	"hostname"
public static final String	CONFIG_KEEP_FIELDS_PRIORITY	"priority"
public static final String	CONFIG_KEEP_FIELDS_TIMESTAMP	"timestamp"
public static final String	CONFIG_KEEP_FIELDS_VERSION	"version"
public static final String	CONFIG_NUMPROCESSORS	"numProcessors"
public static final String	CONFIG_PORT	"port"
public static final String	CONFIG_PORT_CHARSET_PREFIX	"charset.port."
public static final String	CONFIG_PORT_HEADER	"portHeader"
public static final String	CONFIG_PORTS	"ports"
public static final String	CONFIG_READBUF_SIZE	"readBufferBytes"
public static final String	CONFIG_REGEX	"regex"
public static final String	CONFIG_REPLACE	"replace"
public static final String	CONFIG_SEARCH	"search"
public static final int	DEFAULT_BATCHSIZE	100
public static final String	DEFAULT_CHARSET	"UTF-8"
public static final String	DEFAULT_KEEP_FIELDS	"none"
public static final String	DEFAULT_PORT_HEADER	"port"
public static final int	DEFAULT_READBUF_SIZE	1024

org.apache.flume.source.SyslogUDPSource

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_INITIAL_SIZE	2048
public static final int	DEFAULT_MIN_SIZE	2048

org.apache.flume.source.SyslogUtils

Modifier and Type	Constant Field	Value
public static final String	EVENT_STATUS	"flume.syslog.status"
public static final String	KEEP_FIELDS_ALL	"--all--"
public static final int	SYSLOG_BODY_POS	5
public static final String	SYSLOG_FACILITY	"Facility"
public static final int	SYSLOG_HOSTNAME_POS	4
public static final String	SYSLOG_MSG_RFC3164_0	"(?:\\<(\\d{1,3})\\>)(?:(\\d)?\\s?)([A-Z][a-z][a-z]\\s{1,2}\\d{1,2}\\s\\d{2}[:]\\d{2}[:]\\d{2})\\s([\\w][\\w\\d\\.@-]*)\\s(.*)$"
public static final String	SYSLOG_MSG_RFC5424_0	"(?:\\<(\\d{1,3})\\>)(?:(\\d?)\\s?)(?:(\\d{4}[-]\\d{2}[-]\\d{2}[T]\\d{2}[:]\\d{2}[:]\\d{2}(?:\\.\\d{1,6})?(?:[+-]\\d{2}[:]\\d{2}|Z)?)|-)\\s(?:([\\w][\\w\\d\\.@\\-]*)|-)\\s(.*)$"
public static final String	SYSLOG_PRIORITY	"Priority"
public static final int	SYSLOG_PRIORITY_POS	1
public static final String	SYSLOG_SEVERITY	"Severity"
public static final String	SYSLOG_TIMESTAMP_FORMAT_RFC3164_1	"yyyyMMM d HH:mm:ss"
public static final String	SYSLOG_TIMESTAMP_FORMAT_RFC5424_1	"yyyy-MM-dd\'T\'HH:mm:ss.S"
public static final String	SYSLOG_TIMESTAMP_FORMAT_RFC5424_2	"yyyy-MM-dd\'T\'HH:mm:ss.SZ"
public static final String	SYSLOG_TIMESTAMP_FORMAT_RFC5424_3	"yyyy-MM-dd\'T\'HH:mm:ssZ"
public static final String	SYSLOG_TIMESTAMP_FORMAT_RFC5424_4	"yyyy-MM-dd\'T\'HH:mm:ss"
public static final int	SYSLOG_TIMESTAMP_POS	3
public static final String	SYSLOG_VERSION	"Version"
public static final int	SYSLOG_VERSION_POS	2

org.apache.flume.source.ThriftSource

Modifier and Type	Constant Field	Value
public static final String	BINARY_PROTOCOL	"binary"
public static final String	COMPACT_PROTOCOL	"compact"
public static final String	CONFIG_BIND	"bind"
public static final String	CONFIG_PORT	"port"
public static final String	CONFIG_PROTOCOL	"protocol"
public static final String	CONFIG_THREADS	"threads"

org.apache.flume.source.avroLegacy.AvroLegacySource

Modifier and Type	Constant Field	Value
public static final String	HOST	"host"
public static final String	NANOS	"nanos"
public static final String	OG_EVENT	"FlumeOG"
public static final String	PRIORITY	"pri"
public static final String	TIMESTAMP	"timestamp"

org.apache.flume.source.http.BLOBHandler

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_MANDATORY_PARAMETERS	""
public static final String	MANDATORY_PARAMETERS	"mandatoryParameters"
public static final String	PARAMETER_SEPARATOR	","

org.apache.flume.source.http.HTTPSourceConfigurationConstants

Modifier and Type	Constant Field	Value
public static final String	CONFIG_BIND	"bind"
public static final String	CONFIG_HANDLER	"handler"
public static final String	CONFIG_HANDLER_PREFIX	"handler."
public static final String	CONFIG_PORT	"port"
public static final String	DEFAULT_BIND	"0.0.0.0"
public static final String	DEFAULT_HANDLER	"org.apache.flume.source.http.JSONHandler"
public static final String	EXCLUDE_PROTOCOLS	"excludeProtocols"
public static final String	SSL_ENABLED	"enableSSL"
public static final String	SSL_KEYSTORE	"keystore"
public static final String	SSL_KEYSTORE_PASSWORD	"keystorePassword"

org.apache.flume.source.jms.JMSSourceConfiguration

Modifier and Type	Constant Field	Value
public static final String	BATCH_SIZE	"batchSize"
public static final int	BATCH_SIZE_DEFAULT	100
public static final String	CLIENT_ID	"clientId"
public static final String	CONNECTION_FACTORY	"connectionFactory"
public static final String	CONNECTION_FACTORY_DEFAULT	"ConnectionFactory"
public static final String	CONVERTER	"converter"
public static final String	CONVERTER_CHARSET	"converter.charset"
public static final String	CONVERTER_CHARSET_DEFAULT	"UTF-8"
public static final String	CONVERTER_TYPE	"converter.type"
public static final String	CONVERTER_TYPE_DEFAULT	"DEFAULT"
public static final String	CREATE_DURABLE_SUBSCRIPTION	"createDurableSubscription"
public static final boolean	DEFAULT_CREATE_DURABLE_SUBSCRIPTION	false
public static final String	DEFAULT_DURABLE_SUBSCRIPTION_NAME	""
public static final String	DESTINATION_LOCATOR	"destinationLocator"
public static final String	DESTINATION_LOCATOR_DEFAULT	"CDI"
public static final String	DESTINATION_NAME	"destinationName"
public static final String	DESTINATION_TYPE	"destinationType"
public static final String	DESTINATION_TYPE_QUEUE	"queue"
public static final String	DESTINATION_TYPE_TOPIC	"topic"
public static final String	DURABLE_SUBSCRIPTION_NAME	"durableSubscriptionName"
public static final String	ERROR_THRESHOLD	"errorThreshold"
public static final int	ERROR_THRESHOLD_DEFAULT	10
public static final String	INITIAL_CONTEXT_FACTORY	"initialContextFactory"
public static final String	MESSAGE_SELECTOR	"messageSelector"
public static final String	PASSWORD_FILE	"passwordFile"
public static final String	POLL_TIMEOUT	"pollTimeout"
public static final long	POLL_TIMEOUT_DEFAULT	1000L
public static final String	PROVIDER_URL	"providerURL"
public static final String	USERNAME	"userName"

org.apache.flume.source.kafka.KafkaSourceConstants

Modifier and Type	Constant Field	Value
public static final String	AVRO_EVENT	"useFlumeEventFormat"
public static final String	BATCH_DURATION_MS	"batchDurationMillis"
public static final String	BATCH_SIZE	"batchSize"
public static final String	BOOTSTRAP_SERVERS	"kafka.bootstrap.servers"
public static final String	DEFAULT_AUTO_COMMIT	"false"
public static final boolean	DEFAULT_AVRO_EVENT	false
public static final int	DEFAULT_BATCH_DURATION	1000
public static final int	DEFAULT_BATCH_SIZE	1000
public static final String	DEFAULT_GROUP_ID	"flume"
public static final String	DEFAULT_KEY_DESERIALIZER	"org.apache.kafka.common.serialization.StringDeserializer"
public static final boolean	DEFAULT_MIGRATE_ZOOKEEPER_OFFSETS	true
public static final boolean	DEFAULT_SET_TOPIC_HEADER	true
public static final String	DEFAULT_TOPIC_HEADER	"topic"
public static final String	DEFAULT_VALUE_DESERIALIZER	"org.apache.kafka.common.serialization.ByteArrayDeserializer"
public static final String	KAFKA_CONSUMER_PREFIX	"kafka.consumer."
public static final String	KAFKA_PREFIX	"kafka."
public static final String	KEY_HEADER	"key"
public static final String	MIGRATE_ZOOKEEPER_OFFSETS	"migrateZookeeperOffsets"
public static final String	OFFSET_HEADER	"offset"
public static final String	OLD_GROUP_ID	"groupId"
public static final String	PARTITION_HEADER	"partition"
public static final String	SET_TOPIC_HEADER	"setTopicHeader"
public static final String	TIMESTAMP_HEADER	"timestamp"
public static final String	TOPIC	"topic"
public static final String	TOPIC_HEADER	"topicHeader"
public static final String	TOPICS	"kafka.topics"
public static final String	TOPICS_REGEX	"kafka.topics.regex"
public static final String	ZOOKEEPER_CONNECT_FLUME_KEY	"zookeeperConnect"

org.apache.flume.source.scribe.ScribeSource

Modifier and Type	Constant Field	Value
public static final String	SCRIBE_CATEGORY	"category"

org.apache.flume.source.taildir.TaildirSourceConfigurationConstants

Modifier and Type	Constant Field	Value
public static final String	BATCH_SIZE	"batchSize"
public static final String	BYTE_OFFSET_HEADER	"byteOffsetHeader"
public static final String	BYTE_OFFSET_HEADER_KEY	"byteoffset"
public static final String	CACHE_PATTERN_MATCHING	"cachePatternMatching"
public static final int	DEFAULT_BATCH_SIZE	100
public static final boolean	DEFAULT_BYTE_OFFSET_HEADER	false
public static final boolean	DEFAULT_CACHE_PATTERN_MATCHING	true
public static final boolean	DEFAULT_FILE_HEADER	false
public static final String	DEFAULT_FILENAME_HEADER_KEY	"file"
public static final int	DEFAULT_IDLE_TIMEOUT	120000
public static final String	DEFAULT_POSITION_FILE	"/.flume/taildir_position.json"
public static final boolean	DEFAULT_SKIP_TO_END	false
public static final int	DEFAULT_WRITE_POS_INTERVAL	3000
public static final String	FILE_GROUPS	"filegroups"
public static final String	FILE_GROUPS_PREFIX	"filegroups."
public static final String	FILENAME_HEADER	"fileHeader"
public static final String	FILENAME_HEADER_KEY	"fileHeaderKey"
public static final String	HEADERS_PREFIX	"headers."
public static final String	IDLE_TIMEOUT	"idleTimeout"
public static final String	MAX_BATCH_COUNT	"maxBatchCount"
public static final String	POSITION_FILE	"positionFile"
public static final String	SKIP_TO_END	"skipToEnd"
public static final String	WRITE_POS_INTERVAL	"writePosInterval"