|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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_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" |
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.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 |
CHECKPOINT_WRITE_TIMEOUT |
"checkpoint-timeout" |
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 int |
DEFAULT_CHECKPOINT_WRITE_TIMEOUT |
600 |
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 |
1000 |
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 int |
DEFAULT_WRITE_TIMEOUT |
10 |
public static final long |
FLOOR_MINIMUM_REQUIRED_SPACE |
1048576L |
public static final String |
KEEP_ALIVE |
"keep-alive" |
public static final String |
LOG_WRITE_TIMEOUT |
"write-timeout" |
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-" |
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.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.elasticsearch.ElasticSearchSinkConstants | ||
---|---|---|
public static final String |
BATCH_SIZE |
"batchSize" |
public static final String |
CLUSTER_NAME |
"clusterName" |
public static final String |
DEFAULT_CLUSTER_NAME |
"elasticsearch" |
public static final String |
DEFAULT_INDEX_NAME |
"flume" |
public static final String |
DEFAULT_INDEX_TYPE |
"log" |
public static final int |
DEFAULT_PORT |
9300 |
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_TYPE |
"indexType" |
public static final String |
SERIALIZER |
"serializer" |
public static final String |
SERIALIZER_PREFIX |
"serializer." |
public static final String |
TTL |
"ttl" |
org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants | ||
---|---|---|
public static final String |
CONFIG_BATCHSIZE |
"batchSize" |
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.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 |
BATCH_SIZE |
"batchSize" |
public static final String |
BUFFER_MAX_LINE_LENGTH |
"bufferMaxLineLength" |
public static final String |
BUFFER_MAX_LINES |
"bufferMaxLines" |
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 |
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_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_PORT_HEADER |
"port" |
public static final int |
DEFAULT_READBUF_SIZE |
1024 |
org.apache.flume.source.SyslogUtils | ||
---|---|---|
public static final String |
EVENT_STATUS |
"flume.syslog.status" |
public static final int |
SYSLOG_BODY_POS |
3 |
public static final String |
SYSLOG_FACILITY |
"Facility" |
public static final int |
SYSLOG_HOSTNAME_POS |
2 |
public static final String |
SYSLOG_MSG_RFC3164_0 |
"([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\\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_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 |
1 |
org.apache.flume.source.ThriftSource | ||
---|---|---|
public static final String |
CONFIG_BIND |
"bind" |
public static final String |
CONFIG_PORT |
"port" |
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" |
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_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.scribe.ScribeSource | ||
---|---|---|
public static final String |
SCRIBE_CATEGORY |
"category" |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |