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

Modifier and Type	Constant Field	Value
public static final String	JSON	"json"
public static final String	PROPERTIES	"properties"
public static final String	XML	"xml"
public static final String	YAML	"yaml"

org.apache.flume.node.net.UrlConnectionFactory

Modifier and Type	Constant Field	Value
public static final String	HTTP	"http"
public static final String	HTTPS	"https"

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

Modifier and Type	Constant Field	Value
public static final String	ASYNC_PREFIX	"async."
public static final String	ASYNC_ZK_BASEPATH_KEY	"hbase.zookeeper.znode.parent"
public static final String	ASYNC_ZK_QUORUM_KEY	"hbase.zookeeper.quorum"
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.hbase.RegexHbaseEventSerializer

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