Constant Field Values

Contents

• bdglue2.*

bdglue2.*

bdglue2.BDGluePropertyValues

Modifier and Type	Constant Field	Value
public static final String	AVRO_LOCAL_PATH	"bdglue.event.avro-schema-path"
public static final String	AVRO_NAMESPACE	"bdglue.event.avro-namespace"
public static final String	AVRO_SCHEMA_URL	"bdglue.event.avro-hdfs-schema-path"
public static final String	defaultProperties	"/bdglueDefault.properties"
public static final String	ENCODER_CLASS	"bdglue.encoder.class"
public static final String	ENCODER_DELIMITER	"bdglue.encoder.delimiter"
public static final String	ENCODER_DELIMITER_DEFAULT	"001"
public static final String	ENCODER_THREADS	"bdglue.encoder.threads"
public static final String	ENCODER_THREADS_DEFAULT	"2"
public static final String	externalProperties	"bdglue.properties"
public static final String	GENERATE_AVRO_SCHEMA	"bdglue.event.generate-avro-schema"
public static final String	HEADER_AVROPATH	"bdglue.event.header-avropath"
public static final String	HEADER_COLUMNFAMIILY	"bdglue.event.header-columnfamily"
public static final String	HEADER_LONGNAME	"bdglue.event.header-longname"
public static final String	HEADER_OPTYPE	"bdglue.event.header-optype"
public static final String	HEADER_ROWKEY	"bdglue.event.header-rowkey"
public static final String	HEADER_TIMESTAMP	"bdglue.event.header-timestamp"
public static final String	IGNORE_UNCHANGED	"bdglue.encoder.ignore-unchanged"
public static final String	IGNORE_UNCHANGED_DEFAULT	"false"
public static final String	INCLUDE_BEFORES	"bdglue.encoder.include-befores"
public static final String	INCLUDE_BEFORES_DEFAULT	"false"
public static final String	JSON_TEXT	"bdglue.encoder.json.text-only"
public static final String	JSON_TEXT_DEFAULT	"true"
public static final String	NEWLINE_CHAR	"bdglue.encoder.newline-char"
public static final String	NUMERIC_ENCODING	"bdglue.encoder.numeric-encoding"
public static final String	NUMERIC_ENCODING_DEFAULT	"string"
public static final String	PUBLISHER_CLASS	"bdglue.publisher.class"
public static final String	PUBLISHER_HASH	"bdglue.publisher.hash"
public static final String	PUBLISHER_THREADS	"bdglue.publisher.threads"
public static final String	PUBLISHER_THREADS_DEFAULT	"2"
public static final String	REPLACE_NEWLINE	"bdglue.encoder.replace-newline"
public static final String	REPLACE_NEWLINE_DEFAULT	"false"
public static final String	TABLENAME	"bdglue.encoder.tablename"
public static final String	TABLENAME_COLUMN	"bdglue.encoder.tablename-col"
public static final String	TX_OPTYPE	"bdglue.encoder.tx-optype"
public static final String	TX_OPTYPE_COLUMN	"bdglue.encoder.tx-optype-name"
public static final String	TX_POSITION	"bdglue.encoder.tx-position"
public static final String	TX_POSITION_COLUMN	"bdglue.encoder.tx-position-name"
public static final String	TX_TIMESTAMP	"bdglue.encoder.tx-timestamp"
public static final String	TX_TIMESTAMP_COLUMN	"bdglue.encoder.tx-timestamp-name"
public static final String	TXID	"bdglue.encoder.txid"
public static final String	TXID_COLUMN	"bdglue.encoder.txid-col"
public static final String	USERTOKEN	"bdglue.encoder.user-token"
public static final String	USERTOKEN_COLUMN	"bdglue.encoder.user-token-name"

bdglue2.encoder.*

bdglue2.encoder.EventHeader

Modifier and Type	Constant Field	Value
public static final String	avroURL	"flume.avro.schema.url"
public static final String	COLUMN_FAMILY	"columnFamily"
public static final String	OPTYPE	"optype"
public static final String	POSITION	"position"
public static final String	ROWKEY	"rowKey"
public static final String	SHORT_NAME	"shortName"
public static final String	TABLE	"table"
public static final String	TIMESTAMP	"timestamp"
public static final String	TOPIC	"topic"

bdglue2.encoder.EventQueue<T>

Modifier and Type	Constant Field	Value
public static final int	encoderInputQueueSize	5
public static final int	encoderOutputQueueSize	5
public static final int	publisherQueueSize	10
public static final int	publisherThreadQueueSize	10

bdglue2.encoder.avro.AvroSchema

Modifier and Type	Constant Field	Value
public static final int	SCHEMA_ID_UNSET	-9876

bdglue2.meta.*

bdglue2.meta.transaction.DownstreamOperation

Modifier and Type	Constant Field	Value
public static final int	DELETE_ID	3
public static final String	DELETE_VALUE	"DELETE"
public static final int	INSERT_ID	1
public static final String	INSERT_VALUE	"INSERT"
public static final int	INVALID_ID	-1
public static final int	UPDATE_ID	2
public static final String	UPDATE_VALUE	"UPDATE"

bdglue2.publisher.*

bdglue2.publisher.asynchbase.AsyncHbasePublisherPropertyValues

Modifier and Type	Constant Field	Value
public static final String	ASYNC_HBASE_BATCHSIZE	"bdglue.async-hbase.batchSize"
public static final String	ASYNC_HBASE_TIMEOUT	"bdglue.async-hbase.timeout"
public static final String	DEFAULT_BATCHSIZE	"100"
public static final String	DEFAULT_TIMEOUT	"60000"

bdglue2.publisher.bigquery.BigQueryPublisherPropertyValues

Modifier and Type	Constant Field	Value
public static final String	BIGQUERY_BATCH_SIZE	"bdglue.bigquery.batch-size"
public static final String	BIGQUERY_BATCH_SIZE_DEFAULT	"5"
public static final String	BIGQUERY_DATASET	"bdglue.bigquery.dataset"
public static final String	BIGQUERY_DATASET_DEFAULT	"default_dataset"
public static final String	BIGQUERY_FLUSH_FREQ	"bdglue.bigquery.flush-frequency"
public static final String	BIGQUERY_FLUSH_FREQ_DEFAULT	"500"
public static final String	BIGQUERY_INSERT_ONLY	"bdglue.bigquery.insert-only"
public static final String	BIGQUERY_INSERT_ONLY_DEFAULT	"true"

bdglue2.publisher.cassandra.CassandraPublisherPropertyValues

Modifier and Type	Constant Field	Value
public static final String	CASSANDRA_BATCH_SIZE	"bdglue.cassandra.batch-size"
public static final String	CASSANDRA_BATCH_SIZE_DEFAULT	"5"
public static final String	CASSANDRA_CONNECT_NODE	"bdglue.cassandra.node"
public static final String	CASSANDRA_CONNECT_NODE_DEFAULT	"localhost"
public static final String	CASSANDRA_FLUSH_FREQ	"bdglue.cassandra.flush-frequency"
public static final String	CASSANDRA_FLUSH_FREQ_DEFAULT	"500"
public static final String	CASSANDRA_INSERT_ONLY	"bdglue.cassandra.insert-only"
public static final String	CASSANDRA_INSERT_ONLY_DEFAULT	"false"

bdglue2.publisher.flume.FlumePublisherPropertyValues

Modifier and Type	Constant Field	Value
public static final String	FLUME_HOST	"bdglue.flume.host"
public static final String	FLUME_HOST_DEFAULT	"localhost"
public static final String	FLUME_PORT	"bdglue.flume.port"
public static final String	FLUME_PORT_DEFAULT	"41414"
public static final String	FLUME_RPC_RETRIES	"bdglue.flume.rpc.retries"
public static final String	FLUME_RPC_RETRY_DEFAULT	"5"
public static final String	FLUME_RPC_RETRY_DELAY	"bdglue.flume.rpc.retry-delay"
public static final String	FLUME_RPC_RETRY_DELAY_DEFAULT	"10"
public static final String	FLUME_RPC_TYPE	"bdglue.flume.rpc.type"
public static final String	FLUME_RPC_TYPE_DEFAULT	"avro-rpc"

bdglue2.publisher.kafka.KafkaProperties

Modifier and Type	Constant Field	Value
public static final String	BATCH_SIZE_FLUME	"batchSize"
public static final String	BDGLUE_PROPERTY_PREFIX	"bdglue.kafka.producer."
public static final String	BROKER_LIST	"metadata.broker.list"
public static final String	BROKER_LIST_FLUME	"brokerList"
public static final int	DEFAULT_BATCH_SIZE	100
public static final int	DEFAULT_FLUSH_FREQ	500
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-gg-topic"
public static final String	FLUME_PROPERTY_PREFIX	"kafka."
public static final String	KEY_SERIALIZER	"key.serializer.class"
public static final String	MESSAGE_SERIALIZER	"serializer.class"
public static final String	REQUIRED_ACKS	"request.required.acks"
public static final String	REQUIRED_ACKS_FLUME	"requiredAcks"
public static final String	TOPIC_FLUME	"topic"

bdglue2.publisher.kafka.KafkaPublisherPropertyValues

Modifier and Type	Constant Field	Value
public static final String	KAFKA_BATCH_SIZE	"bdglue.kafka.batchSize"
public static final String	KAFKA_BROKER_LIST	"bdglue.kafka.metadata.broker.list"
public static final String	KAFKA_FLUSH_FREQ	"bdglue.kafka.flushFreq"
public static final String	KAFKA_KEY_SERIALIZER	"bdglue.kafka.key.serializer.class"
public static final String	KAFKA_MESSAGE_METADATA	"bdglue.kafka.metadata.helper.class"
public static final String	KAFKA_MESSAGE_SERIALIZER	"bdglue.kafka.serializer.class"
public static final String	KAFKA_REGISTRY_ID_SIZE	"bdglue.kafka.registry.id-size"
public static final String	KAFKA_REGISTRY_MAGIC_BYTE	"bdglue.kafka.registry.magic-byte"
public static final String	KAFKA_REGISTRY_MAX_SCHEMAS	"bdglue.kafka.registry.max-schemas-per-subject"
public static final String	KAFKA_REGISTRY_URL	"bdglue.kafka.producer.schema.registry.url"
public static final String	KAFKA_REQUIRED_ACKS	"bdglue.kafka.request.required.acks"
public static final String	KAFKA_TOPIC	"bdglue.kafka.topic"

bdglue2.publisher.nosql.NoSQLPublisherPropertyValues

Modifier and Type	Constant Field	Value
public static final String	NOSQL_API	"bdglue.nosql.api"
public static final String	NOSQL_API_DEFAULT	"kv_api"
public static final String	NOSQL_DURABILITY	"bdglue.nosql.durability"
public static final String	NOSQL_DURABILITY_DEFAULT	"WRITE_NO_SYNC"
public static final String	NOSQL_HOST	"bdglue.nosql.host"
public static final String	NOSQL_HOST_DEFAULT	"localhost"
public static final String	NOSQL_KVSTORE	"bdglue.nosql.kvstore"
public static final String	NOSQL_KVSTORE_DEFAULT	"kvstore"
public static final String	NOSQL_PORT	"bdglue.nosql.port"
public static final String	NOSQL_PORT_DEFAULT	"5000"

bdglue2.utility.*

bdglue2.utility.schemadef.SchemaDefPropertyValues

Modifier and Type	Constant Field	Value
public static final String	AVRO_URL	"schemadef.avro-url"
public static final String	defaultProperties	"/schemadefDefault.properties"
public static final String	externalProperties	"schemadef.properties"
public static final String	JDBC_DRIVER	"schemadef.jdbc.driver"
public static final String	JDBC_PASSWORD	"schemadef.jdbc.password"
public static final String	JDBC_TABLES	"schemadef.jdbc.tables"
public static final String	JDBC_URL	"schemadef.jdbc.url"
public static final String	JDBC_USER	"schemadef.jdbc.username"
public static final String	LOCATION	"schemadef.data-location"
public static final String	NUMERIC_ENCODING	"schemadef.numeric-encoding"
public static final String	OPTYPE_COLUMN	"schemadef.tx-optype-name"
public static final String	OUTPUT_FORMAT	"schemadef.output.format"
public static final String	OUTPUT_PATH	"schemadef.output.path"
public static final String	POSITION_COLUMN	"schemadef.tx-position-name"
public static final String	REPLACE_CHAR	"schemadef.replace.invalid_char"
public static final String	REPLACE_CHAR_DEFAULT	"_"
public static final String	REPLACE_FIRST	"schemadef.replace.invalid_first_char"
public static final String	REPLACE_FIRST_DEFAULT	"x"
public static final String	REPLACE_REGEX	"schemadef.replace.regex"
public static final String	REPLACE_REGEX_DEFAULT	"[^a-zA-Z0-9_\\.]"
public static final String	REPLICATION_STRATEGY	"schemadef.cassandra.replication-strategy"
public static final String	REPLICATION_STRATEGY_DEFAULT	"{ \'class\' : \'SimpleStrategy\', \'replication_factor\' : 1 }"
public static final String	SET_DEFAULTS	"schemadef.set-defaults"
public static final String	SET_OPTYPE	"schemadef.tx-optype"
public static final String	SET_POSITION	"schemadef.tx-position"
public static final String	SET_TABLENAME	"schemadef.tablename"
public static final String	SET_TIMESTAMP	"schemadef.tx-timestamp"
public static final String	SET_TXID	"schemadef.txid"
public static final String	SET_USERTOKEN	"schemadef.user-token"
public static final String	TABLENAME_COLUMN	"schemadef.tablename-col"
public static final String	TIMESTAMP_COLUMN	"schemadef.tx-timestamp-name"
public static final String	TXID_COLUMN	"schemadef.txid-col"
public static final String	USERTOKEN_COLUMN	"schemadef.user-token-name"