|
||||||||||
| 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.api.RpcClientConfigurationConstants | ||
|---|---|---|
public static final String |
CONFIG_BATCH_SIZE |
"batch-size" |
public static final String |
CONFIG_CLIENT_TYPE |
"client.type" |
public static final String |
CONFIG_CONNECT_TIMEOUT |
"connect-timeout" |
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_REQUEST_TIMEOUT |
"request-timeout" |
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 |
DEFAULT_MULTIPLEX_HEADER |
"flume.selector.header" |
| org.apache.flume.channel.file.FileChannelConfiguration | ||
|---|---|---|
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 int |
DEFAULT_TRANSACTION_CAPACITY |
1000 |
public static final int |
DEFAULT_WRITE_TIMEOUT |
10 |
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 |
TRANSACTION_CAPACITY |
"transactionCapacity" |
| 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.recoverable.memory.RecoverableMemoryChannel | ||
|---|---|---|
public static final String |
CAPACITY |
"capacity" |
public static final int |
DEFAULT_CAPACITY |
100 |
public static final int |
DEFAULT_KEEPALIVE |
3 |
public static final String |
KEEPALIVE |
"keep-alive" |
public static final String |
WAL_DATA_DIR |
"wal.dataDir" |
public static final String |
WAL_MAX_LOGS_SIZE |
"wal.maxLogsSize" |
public static final String |
WAL_MIN_RETENTION_PERIOD |
"wal.minRetentionPeriod" |
public static final String |
WAL_ROLL_SIZE |
"wal.rollSize" |
public static final String |
WAL_WORKER_INTERVAL |
"wal.workerInterval" |
| org.apache.flume.channel.recoverable.memory.wal.WAL<T extends org.apache.hadoop.io.Writable> | ||
|---|---|---|
public static final long |
DEFAULT_MAX_LOGS_SIZE |
536870912L |
public static final long |
DEFAULT_MIN_LOG_RETENTION_PERIOD |
300000L |
public static final long |
DEFAULT_ROLL_SIZE |
67108864L |
public static final long |
DEFAULT_WORKER_INTERVAL |
60000L |
| 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.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.sink.LoadBalancingSinkProcessor | ||
|---|---|---|
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_ROUND_ROBIN |
"ROUND_ROBIN" |
| 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_SERIALIZER |
"serializer" |
public static final String |
CONFIG_SERIALIZER_PREFIX |
"serializer." |
public static final String |
CONFIG_TABLE |
"table" |
| org.apache.flume.sink.hbase.RegexHbaseEventSerializer | ||
|---|---|---|
public static final String |
COL_NAME_CONFIG |
"colNames" |
public static final String |
COLUMN_NAME_DEFAULT |
"payload" |
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 |
"(.*)" |
| org.apache.flume.source.ExecSourceConfigurationConstants | ||
|---|---|---|
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 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_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.SyslogSourceConfigurationConstants | ||
|---|---|---|
public static final String |
CONFIG_DATEFORMAT |
"dateFormat" |
public static final String |
CONFIG_FORMAT_PREFIX |
"format." |
public static final String |
CONFIG_HOST |
"host" |
public static final String |
CONFIG_PORT |
"port" |
public static final String |
CONFIG_REGEX |
"regex" |
public static final String |
CONFIG_REPLACE |
"replace" |
public static final String |
CONFIG_SEARCH |
"search" |
| 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.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" |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||