Constant Field Values

Contents

• org.apache.*

org.apache.*

org.apache.flume.Constants

public static final String

SYSPROP_CALLED_FROM_SERVICE

"flume.called.from.service"

org.apache.flume.api.NettyAvroRpcClient.Builder

protected static final int

DEFAULT_BATCH_SIZE

100

org.apache.flume.channel.MultiplexingChannelSelector

public static final String	CONFIG_MULTIPLEX_HEADER_NAME	"header"
public static final String	CONFIG_PREFIX_DEFAULT	"default"
public static final String	CONFIG_PREFIX_MAPPING	"mapping"
public static final String	DEFAULT_MULTIPLEX_HEADER	"flume.selector.header"

org.apache.flume.channel.jdbc.ConfigurationConstants

public static final String	CONFIG_CREATE_INDEX	"org.apache.flume.channel.jdbc.create.index"
public static final String	CONFIG_CREATE_SCHEMA	"org.apache.flume.channel.jdbc.create.schema"
public static final String	CONFIG_DATABASE_TYPE	"org.apache.flume.channel.jdbc.db.type"
public static final String	CONFIG_JDBC_DRIVER_CLASS	"org.apache.flume.channel.jdbc.driver.class"
public static final String	CONFIG_JDBC_PROPERTIES_FILE	"org.apache.flume.channel.jdbc.connection.properties.file"
public static final String	CONFIG_JDBC_SYSPRO_PREFIX	"org.apache.flume.channel.jdbc.sysprop."
public static final String	CONFIG_MAX_CAPACITY	"org.apache.flume.channel.jdbc.maximum.capacity"
public static final String	CONFIG_MAX_CONNECTION	"org.apache.flume.channel.jdbc.maximum.connections"
public static final String	CONFIG_PASSWORD	"org.apache.flume.channel.jdbc.db.password"
public static final String	CONFIG_TX_ISOLATION_LEVEL	"org.apache.flume.channel.jdbc.transaction.isolation"
public static final String	CONFIG_URL	"org.apache.flume.channel.jdbc.driver.url"
public static final String	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	"CREATE TABLE FLUME.FL_PLSPILL ( FLP_EVENT BIGINT, FLP_SPILL BLOB, FOREIGN KEY (FLP_EVENT) REFERENCES FLUME.FL_EVENT (FLE_ID))"
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.formatter.output.BucketPath

public static final String

TAG_REGEX

"\\%(\\w|\\%)|\\%\\{([\\w\\.-]+)\\}"

org.apache.flume.source.SyslogTcpSource

public static final int

SYSLOG_TCP_PORT

514

org.apache.flume.source.SyslogUDPSource

public static final int

SYSLOG_UDP_PORT

514

org.apache.flume.source.SyslogUtils

public static final String	SYSLOG_FACILITY	"Facility"
public static final String	SYSLOG_SEVERITY	"Severity"

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"