| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
READ_BUFFER_UNIT |
2048 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
DEFAULT_SCAN_CACHING |
1000 |
public static final int |
LOOKAHEAD_SCAN_SEEK |
2 |
public static final long |
TIMER_DELAY_SCHEDULE |
3000L |
public static final long |
TIMER_PERIOD_SCHEDULE |
10000L |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
HBASE_ZK_NODE_ROOT |
"zookeeper.znode.parent" |
public static final String |
HBASE_ZK_PORT |
"hbase.zookeeper.property.clientPort" |
public static final String |
HBASE_ZK_QUORUM |
"hbase.zookeeper.quorum" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
HIGH_AUTO_COMMIT_INTERVAL |
"auto.commit.interval.ms" |
public static final String |
HIGH_GROUP_ID |
"group.id" |
public static final String |
HIGH_TOPIC |
"high.level.topic" |
public static final String |
HIGH_ZOOKEEPER_CONN |
"zookeeper.connect" |
public static final String |
HIGH_ZOOKEEPER_SESSION_TIMEOUT |
"zookeeper.session.timeout.ms" |
public static final String |
HIGH_ZOOKEEPER_SYNC_TIME |
"zookeeper.sync.time.ms" |
public static final String |
JDQ_COMPRESSION |
"jdq.compression" |
public static final String |
JDQ_IS_CONTROL_SPEED |
"jdq.is.control.speed" |
public static final String |
JDQ_IS_SYNC |
"jdq.is.sync" |
public static final String |
JDQ_REPLICA_LEVEL |
"jdq.replica.level" |
public static final String |
JDQ_ZK_INFO |
"jdq.zk.info" |
public static final String |
PRODUCER_ACKS |
"request.required.acks" |
public static final String |
PRODUCER_BROKER_LIST |
"metadata.broker.list" |
public static final String |
PRODUCER_COMPRESSION_CODEC |
"compression.codec" |
public static final String |
PRODUCER_KEY_SERIALIZER_CLASS |
"key.serializer.class" |
public static final String |
PRODUCER_PARTITION_CLASS |
"partitioner.class" |
public static final String |
PRODUCER_REQUEST_TIMEOUT |
"request.timeout.ms" |
public static final String |
PRODUCER_TYPE |
"producer.mtype" |
public static final String |
PRODUCER_VALUE_SERIALIZER_CLASS |
"serializer.class" |
public static final String |
SIMPLE_BROKER_LIST |
"simple.brokers" |
public static final String |
SIMPLE_END_OFFSETS |
"simple.end.offsets" |
public static final String |
SIMPLE_OFFSETS |
"simple.offsets" |
public static final String |
SIMPLE_PARTITIONS |
"simple.partitions" |
public static final String |
SIMPLE_TOPIC |
"simple.topic" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
QUEUE_SIZE |
10000 |
public static final long |
SLEEPING_INTERVAL |
3000L |
public static final int |
THREAD_COUNT |
5 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
CONF_SPLIT |
"," |
public static final int |
CONSUME_BUFFER_SIZE |
65536 |
public static final int |
CONSUME_TIME_OUT |
100000 |
public static final int |
ERR_COUNT_RECONN |
5 |
public static final int |
FETCH_SIZE |
1048576 |
public static final String |
PORT_SPLIT |
":" |
public static final int |
QUEUE_SIZE |
10000 |
public static final long |
SLEEPING_TIME |
3000L |
public static final int |
THREAD_POOL_SIZE |
100 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final long |
SLEEPING_TIME |
3000L |
public static final String |
ZK_IDS_PATH |
"/brokers/ids" |
public static final String |
ZK_TOPICS_PATH |
"/brokers/topics" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
QUEUE_DEFAULT_SIZE |
10000 |
public static final int |
RANDOM_INT_RANGE |
9999 |
public static final long |
RANDOM_LONG_RANGE |
999999999L |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
MYSQL_DATABASE |
"mysql.database" |
public static final String |
MYSQL_HOST |
"mysql.host" |
public static final String |
MYSQL_PASSWORD |
"mysql.password" |
public static final String |
MYSQL_PORT |
"mysql.port" |
public static final String |
MYSQL_USER |
"mysql.user" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
DEFAULT_CHARSET |
"UTF-8" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
CONN_TIME_OUT |
30000 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
BATCH_SIZE |
10000 |
public static final String |
PRIMARY_INPUT_CONN |
"," |
public static final String |
PRIMARY_ROWKEY_CONN |
":" |
public static final int |
QUEUE_LENGTH |
10000 |
public static final long |
SEND_INTERVAL |
3000L |
public static final long |
SLEEP_INTERVAL |
5000L |
public static final long |
SLEEP_SHORT_INTERVAL |
500L |
public static final long |
TIMER_DELAY |
3000L |
public static final long |
TIMER_PERIOD |
30000L |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
KEY_FORMAT |
".jrdw.jd.com" |
public static final String |
KEY_FORMAT_TEST |
".jrdw.jd.com_test" |
public static final int |
TIMEOUT |
300000 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
BDP_URL |
"http://train.bdp.jd.com/api/ztc/job/getJobConfig.ajax?jobId=" |
public static final String |
FILE_NAME |
"job.list" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
CHECKPOINT_PATH |
"/checkpoint" |
public static final String |
JOB_LIST |
"job.list" |
public static final String |
SET_CMD |
"set" |
public static final String |
SHELL_CONF |
"config.conf" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final long |
SLEEP_INTERVAL |
5000L |
Copyright © 2016. All rights reserved.