Overview  Package  Class  Use  Tree  Deprecated  Index  Help 
 PREV   NEXT FRAMES    NO FRAMES    

Constant Field Values

Contents
org.apache.*

org.apache.flume.Constants
public static final String SYSPROP_CALLED_FROM_SERVICE "flume.called.from.service"

org.apache.flume.agent.embedded.EmbeddedAgentConfiguration
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
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_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_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
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
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
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
public static final String CONFIG_OPTIONAL "optional"

org.apache.flume.channel.SpillableMemoryChannel
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
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
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
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
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
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
public static final int COUNT_FIELD_NUMBER 2
public static final int LOGFILEID_FIELD_NUMBER 1

org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
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
public static final int TYPE_FIELD_NUMBER 1

org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
public static final int BODY_FIELD_NUMBER 2
public static final int HEADERS_FIELD_NUMBER 1

org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
public static final int KEY_FIELD_NUMBER 1
public static final int VALUE_FIELD_NUMBER 2

org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
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
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
public static final int CHECKSUM_FIELD_NUMBER 2
public static final int EVENT_FIELD_NUMBER 1

org.apache.flume.channel.file.proto.ProtosFactory.Take
public static final int FILEID_FIELD_NUMBER 1
public static final int OFFSET_FIELD_NUMBER 2

org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
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
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
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
public static final String AUTO_COMMIT_ENABLED "auto.commit.enable"
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_GROUP_ID "flume"
public static final boolean DEFAULT_PARSE_AS_FLUME_EVENT true
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 GROUP_ID "group.id"
public static final String GROUP_ID_FLUME "groupId"
public static final String KAFKA_PREFIX "kafka."
public static final String PARSE_AS_FLUME_EVENT "parseAsFlumeEvent"
public static final String READ_SMALLEST_OFFSET "readSmallestOffset"
public static final String REQUIRED_ACKS_KEY "request.required.acks"
public static final String TIMEOUT "timeout"
public static final String TOPIC "topic"
public static final String ZOOKEEPER_CONNECT "zookeeper.connect"
public static final String ZOOKEEPER_CONNECT_FLUME_KEY "zookeeperConnect"

org.apache.flume.conf.BasicConfigurationConstants
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_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
public static final String INDENTSTEP " "

org.apache.flume.formatter.output.BucketPath
public static final String TAG_REGEX "\\%(\\w|\\%)|\\%\\{([\\w\\.-]+)\\}"

org.apache.flume.instrumentation.GangliaServer
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
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
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.node.Application
public static final String CONF_MONITOR_CLASS "flume.monitoring.type"
public static final String CONF_MONITOR_PREFIX "flume.monitoring."

org.apache.flume.serialization.AvroEventDeserializer
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
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 SYNC_INTERVAL_BYTES "syncIntervalBytes"

org.apache.flume.serialization.EventSerializer
public static final String CTX_PREFIX "serializer."

org.apache.flume.serialization.LineDeserializer
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
public static final int DEFAULT_BUF_SIZE 16384

org.apache.flume.sink.LoadBalancingSinkProcessor
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
public static final int DEFAULT_MAX_BYTE_DUMP 16
public static final String MAX_BYTES_DUMP_KEY "maxBytesToLog"

org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
public static final String BATCH_SIZE "batchSize"
public static final String CLIENT_PREFIX "client."
public static final String CLIENT_TYPE "client"
public static final String CLUSTER_NAME "clusterName"
public static final String DEFAULT_CLIENT_TYPE "transport"
public static final String DEFAULT_CLUSTER_NAME "elasticsearch"
public static final String DEFAULT_INDEX_NAME "flume"
public static final String DEFAULT_INDEX_NAME_BUILDER_CLASS "org.apache.flume.sink.elasticsearch.TimeBasedIndexNameBuilder"
public static final String DEFAULT_INDEX_TYPE "log"
public static final int DEFAULT_PORT 9300
public static final String DEFAULT_SERIALIZER_CLASS "org.apache.flume.sink.elasticsearch.ElasticSearchLogStashEventSerializer"
public static final int DEFAULT_TTL -1
public static final String HOSTNAMES "hostNames"
public static final String INDEX_NAME "indexName"
public static final String INDEX_NAME_BUILDER "indexNameBuilder"
public static final String INDEX_NAME_BUILDER_PREFIX "indexNameBuilder."
public static final String INDEX_TYPE "indexType"
public static final String SERIALIZER "serializer"
public static final String SERIALIZER_PREFIX "serializer."
public static final String TTL "ttl"
public static final String TTL_REGEX "^(\\d+)(\\D*)"

org.apache.flume.sink.elasticsearch.TimeBasedIndexNameBuilder
public static final String DATE_FORMAT "dateFormat"
public static final String DEFAULT_DATE_FORMAT "yyyy-MM-dd"
public static final String DEFAULT_TIME_ZONE "Etc/UTC"
public static final String TIME_ZONE "timeZone"

org.apache.flume.sink.elasticsearch.client.ElasticSearchClientFactory
public static final String RestClient "rest"
public static final String TransportClient "transport"

org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
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_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 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
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 INGORE_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
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.hive.Config
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
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
public static final String ALIAS "JSON"

org.apache.flume.sink.kafka.KafkaSink
public static final String KEY_HDR "key"
public static final String TOPIC_HDR "topic"

org.apache.flume.sink.kafka.KafkaSinkConstants
public static final String BATCH_SIZE "batchSize"
public static final String BROKER_LIST_FLUME_KEY "brokerList"
public static final String BROKER_LIST_KEY "metadata.broker.list"
public static final int DEFAULT_BATCH_SIZE 100
public static final String DEFAULT_KEY_SERIALIZER "kafka.serializer.StringEncoder"
public static final String DEFAULT_MESSAGE_SERIALIZER "kafka.serializer.DefaultEncoder"
public static final String DEFAULT_REQUIRED_ACKS "1"
public static final String DEFAULT_TOPIC "default-flume-topic"
public static final String KEY_SERIALIZER_KEY "key.serializer.class"
public static final String MESSAGE_SERIALIZER_KEY "serializer.class"
public static final String PROPERTY_PREFIX "kafka."
public static final String REQUIRED_ACKS_FLUME_KEY "requiredAcks"
public static final String REQUIRED_ACKS_KEY "request.required.acks"
public static final String TOPIC "topic"

org.apache.flume.sink.kite.DatasetSinkConstants
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
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
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
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
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
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
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
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 int DEFAULT_MAX_LINE_LENGTH 512

org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
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_INPUT_CHARSET "UTF-8"
public static final String DEFAULT_SPOOLED_FILE_SUFFIX ".COMPLETED"
public static final String DEFAULT_TRACKER_DIR ".flumespool"
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 INPUT_CHARSET "inputCharset"
public static final String MAX_BACKOFF "maxBackoff"
public static final String SPOOL_DIRECTORY "spoolDir"
public static final String SPOOLED_FILE_SUFFIX "fileSuffix"
public static final String TRACKER_DIR "trackerDir"

org.apache.flume.source.SyslogSourceConfigurationConstants
public static final String CONFIG_BATCHSIZE "batchSize"
public static final String CONFIG_CHARSET "charset.default"
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
public static final int DEFAULT_INITIAL_SIZE 2048
public static final int DEFAULT_MIN_SIZE 2048

org.apache.flume.source.SyslogUtils
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
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
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.HTTPSourceConfigurationConstants
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
public static final String BATCH_SIZE "batchSize"
public static final int BATCH_SIZE_DEFAULT 100
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 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 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
public static final String AUTO_COMMIT_ENABLED "auto.commit.enable"
public static final String BATCH_DURATION_MS "batchDurationMillis"
public static final String BATCH_SIZE "batchSize"
public static final String CONSUMER_TIMEOUT "consumer.timeout.ms"
public static final String DEFAULT_AUTO_COMMIT "false"
public static final int DEFAULT_BATCH_DURATION 1000
public static final int DEFAULT_BATCH_SIZE 1000
public static final String DEFAULT_CONSUMER_TIMEOUT "10"
public static final String DEFAULT_GROUP_ID "flume"
public static final String GROUP_ID "group.id"
public static final String GROUP_ID_FLUME "groupId"
public static final String KEY "key"
public static final String PROPERTY_PREFIX "kafka."
public static final String TIMESTAMP "timestamp"
public static final String TOPIC "topic"
public static final String ZOOKEEPER_CONNECT "zookeeper.connect"
public static final String ZOOKEEPER_CONNECT_FLUME "zookeeperConnect"

org.apache.flume.source.scribe.ScribeSource
public static final String SCRIBE_CATEGORY "category"

Overview  Package  Class  Use  Tree  Deprecated  Index  Help 
 PREV   NEXT FRAMES    NO FRAMES    
Copyright © 2009-2015 Apache Software Foundation. All Rights Reserved.