Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
STORM_ZOOKEEPER_CONNECTION_TIMEOUT |
"storm.zookeeper.connection.timeout" |
public static final java.lang.String |
STORM_ZOOKEEPER_PORT |
"storm.zookeeper.port" |
public static final java.lang.String |
STORM_ZOOKEEPER_RETRY_INTERVAL |
"storm.zookeeper.retry.interval" |
public static final java.lang.String |
STORM_ZOOKEEPER_RETRY_TIMES |
"storm.zookeeper.retry.times" |
public static final java.lang.String |
STORM_ZOOKEEPER_SERVERS |
"storm.zookeeper.servers" |
public static final java.lang.String |
STORM_ZOOKEEPER_SESSION_TIMEOUT |
"storm.zookeeper.session.timeout" |
public static final java.lang.String |
STORMCOMPAT_TOPOLOGY_AUTO_TASK_HOOKS |
"stormcompat.topology.auto.task.hooks" |
public static final java.lang.String |
TOPOLOGY_ACKER_EXECUTORS |
"topology.acker.executors" |
public static final java.lang.String |
TOPOLOGY_AUTO_TASK_HOOKS |
"topology.auto.task.hooks" |
public static final java.lang.String |
TOPOLOGY_CAP_TICKET |
"topology.cap.ticket" |
public static final java.lang.String |
TOPOLOGY_DEBUG |
"topology.debug" |
public static final java.lang.String |
TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS |
"topology.enable.message.timeouts" |
public static final java.lang.String |
TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS |
"topology.error.throttle.interval.secs" |
public static final java.lang.String |
TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION |
"topology.fall.back.on.java.serialization" |
public static final java.lang.String |
TOPOLOGY_KRYO_DECORATORS |
"topology.kryo.decorators" |
public static final java.lang.String |
TOPOLOGY_KRYO_FACTORY |
"topology.kryo.factory" |
public static final java.lang.String |
TOPOLOGY_KRYO_REGISTER |
"topology.kryo.register" |
public static final java.lang.String |
TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL |
"topology.max.error.report.per.interval" |
public static final java.lang.String |
TOPOLOGY_MAX_SPOUT_PENDING |
"topology.max.spout.pending" |
public static final java.lang.String |
TOPOLOGY_MAX_TASK_PARALLELISM |
"topology.max.task.parallelism" |
public static final java.lang.String |
TOPOLOGY_MESSAGE_TIMEOUT_SECS |
"topology.message.timeout.secs" |
public static final java.lang.String |
TOPOLOGY_METRICS_CONSUMER_REGISTER |
"topology.metrics.consumer.register" |
public static final java.lang.String |
TOPOLOGY_NAME |
"topology.name" |
public static final java.lang.String |
TOPOLOGY_OPTIMIZE |
"topology.optimize" |
public static final java.lang.String |
TOPOLOGY_PROJECT_NAME |
"topology.project.name" |
public static final java.lang.String |
TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS |
"topology.skip.missing.kryo.registrations" |
public static final java.lang.String |
TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS |
"topology.sleep.spout.wait.strategy.time.ms" |
public static final java.lang.String |
TOPOLOGY_SPOUT_WAIT_STRATEGY |
"topology.spout.wait.strategy" |
public static final java.lang.String |
TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS |
"topology.state.synchronization.timeout.secs" |
public static final java.lang.String |
TOPOLOGY_STATS_SAMPLE_RATE |
"topology.stats.sample.rate" |
public static final java.lang.String |
TOPOLOGY_TASKS |
"topology.tasks" |
public static final java.lang.String |
TOPOLOGY_TEAM_EMAIL |
"topology.team.email" |
public static final java.lang.String |
TOPOLOGY_TEAM_NAME |
"topology.team.name" |
public static final java.lang.String |
TOPOLOGY_TICK_TUPLE_FREQ_SECS |
"topology.tick.tuple.freq.secs" |
public static final java.lang.String |
TOPOLOGY_TRANSACTIONAL_ID |
"topology.transactional.id" |
public static final java.lang.String |
TOPOLOGY_WORKER_CHILDOPTS |
"topology.worker.childopts" |
public static final java.lang.String |
TOPOLOGY_WORKERS |
"topology.workers" |
public static final java.lang.String |
TRANSACTIONAL_ZOOKEEPER_PORT |
"transactional.zookeeper.port" |
public static final java.lang.String |
TRANSACTIONAL_ZOOKEEPER_ROOT |
"transactional.zookeeper.root" |
public static final java.lang.String |
TRANSACTIONAL_ZOOKEEPER_SERVERS |
"transactional.zookeeper.servers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SYSTEM_COMPONENT_ID |
"__system" |
public static final java.lang.String |
SYSTEM_TICK_STREAM_ID |
"__tick" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_STREAM_ID |
"default" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
TOPOLOGY_ADDITIONAL_CLASSPATH |
"topology.additional.classpath" |
public static final java.lang.String |
TOPOLOGY_AUTO_TASK_HOOKS |
"topology.auto.task.hooks" |
public static final java.lang.String |
TOPOLOGY_CAP_TICKET |
"topology.cap.ticket" |
public static final java.lang.String |
TOPOLOGY_COMPONENT_JVMOPTS |
"topology.component.jvmopts" |
public static final java.lang.String |
TOPOLOGY_COMPONENT_PARALLELISM |
"topology.component.parallelism" |
public static final java.lang.String |
TOPOLOGY_COMPONENT_RAMMAP |
"topology.component.rammap" |
public static final java.lang.String |
TOPOLOGY_CONTAINER_CPU_REQUESTED |
"topology.container.cpu" |
public static final java.lang.String |
TOPOLOGY_CONTAINER_DISK_REQUESTED |
"topology.container.disk" |
public static final java.lang.String |
TOPOLOGY_CONTAINER_MAX_CPU_HINT |
"topology.container.max.cpu.hint" |
public static final java.lang.String |
TOPOLOGY_CONTAINER_MAX_DISK_HINT |
"topology.container.max.disk.hint" |
public static final java.lang.String |
TOPOLOGY_CONTAINER_MAX_RAM_HINT |
"topology.container.max.ram.hint" |
public static final java.lang.String |
TOPOLOGY_CONTAINER_PADDING_PERCENTAGE |
"topology.container.padding.percentage" |
public static final java.lang.String |
TOPOLOGY_CONTAINER_RAM_REQUESTED |
"topology.container.ram" |
public static final java.lang.String |
TOPOLOGY_DEBUG |
"topology.debug" |
public static final java.lang.String |
TOPOLOGY_ENABLE_ACKING |
"topology.acking" |
public static final java.lang.String |
TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS |
"topology.enable.message.timeouts" |
public static final java.lang.String |
TOPOLOGY_MAX_SPOUT_PENDING |
"topology.max.spout.pending" |
public static final java.lang.String |
TOPOLOGY_MESSAGE_TIMEOUT_SECS |
"topology.message.timeout.secs" |
public static final java.lang.String |
TOPOLOGY_NAME |
"topology.name" |
public static final java.lang.String |
TOPOLOGY_PROJECT_NAME |
"topology.project.name" |
public static final java.lang.String |
TOPOLOGY_SERIALIZER_CLASSNAME |
"topology.serializer.classname" |
public static final java.lang.String |
TOPOLOGY_STMGRS |
"topology.stmgrs" |
public static final java.lang.String |
TOPOLOGY_TEAM_EMAIL |
"topology.team.email" |
public static final java.lang.String |
TOPOLOGY_TEAM_NAME |
"topology.team.name" |
public static final java.lang.String |
TOPOLOGY_TICK_TUPLE_FREQ_SECS |
"topology.tick.tuple.freq.secs" |
public static final java.lang.String |
TOPOLOGY_UPDATE_DEACTIVATE_WAIT_SECS |
"topology.update.deactivate.wait.secs" |
public static final java.lang.String |
TOPOLOGY_UPDATE_REACTIVATE_WAIT_SECS |
"topology.update.reactivate.wait.secs" |
public static final java.lang.String |
TOPOLOGY_WORKER_CHILDOPTS |
"topology.worker.childopts" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COMP_FIELD_NUMBER |
1 |
public static final int |
INPUTS_FIELD_NUMBER |
2 |
public static final int |
OUTPUTS_FIELD_NUMBER |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CLASS_NAME_FIELD_NUMBER |
2 |
public static final int |
CONFIG_FIELD_NUMBER |
3 |
public static final int |
NAME_FIELD_NUMBER |
1 |
public static final int |
SERIALIZED_OBJECT_FIELD_NUMBER |
4 |
public static final int |
SPEC_FIELD_NUMBER |
5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
JAVA_CLASS_NAME_VALUE |
1 |
public static final int |
JAVA_SERIALIZED_OBJECT_VALUE |
2 |
public static final int |
PYTHON_CLASS_NAME_VALUE |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
KVS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
KEY_FIELD_NUMBER |
1 |
public static final int |
SERIALIZED_VALUE_FIELD_NUMBER |
3 |
public static final int |
TYPE_FIELD_NUMBER |
4 |
public static final int |
VALUE_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
JAVA_SERIALIZED_VALUE_VALUE |
2 |
public static final int |
PYTHON_SERIALIZED_VALUE_VALUE |
3 |
public static final int |
STRING_VALUE_VALUE |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
JAVA_OBJECT_VALUE |
1 |
public static final int |
PYTHON_OBJECT_VALUE |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ALL_VALUE |
3 |
public static final int |
CUSTOM_VALUE |
7 |
public static final int |
DIRECT_VALUE |
6 |
public static final int |
FIELDS_VALUE |
2 |
public static final int |
LOWEST_VALUE |
4 |
public static final int |
NONE_VALUE |
5 |
public static final int |
SHUFFLE_VALUE |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CUSTOM_GROUPING_OBJECT_FIELD_NUMBER |
4 |
public static final int |
GROUPING_FIELDS_FIELD_NUMBER |
3 |
public static final int |
GTYPE_FIELD_NUMBER |
2 |
public static final int |
STREAM_FIELD_NUMBER |
1 |
public static final int |
TYPE_FIELD_NUMBER |
5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SCHEMA_FIELD_NUMBER |
2 |
public static final int |
STREAM_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COMP_FIELD_NUMBER |
1 |
public static final int |
OUTPUTS_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COMPONENT_NAME_FIELD_NUMBER |
2 |
public static final int |
ID_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
KEYS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
KEY_FIELD_NUMBER |
1 |
public static final int |
TYPE_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
BOLTS_FIELD_NUMBER |
4 |
public static final int |
ID_FIELD_NUMBER |
1 |
public static final int |
NAME_FIELD_NUMBER |
2 |
public static final int |
SPOUTS_FIELD_NUMBER |
3 |
public static final int |
STATE_FIELD_NUMBER |
5 |
public static final int |
TOPOLOGY_CONFIG_FIELD_NUMBER |
6 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
KILLED_VALUE |
3 |
public static final int |
PAUSED_VALUE |
2 |
public static final int |
RUNNING_VALUE |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
OBJECT_VALUE |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ROOT_NAME |
"__auto__" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_STREAM_ID |
"default" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MB_TO_BYTES |
1048576 |
public static final long |
MILLISECONDS_TO_NANOSECONDS |
1000000L |
public static final long |
SECONDS_TO_MILLISECONDS |
1000L |
public static final long |
SECONDS_TO_NANOSECONDS |
1000000000L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NUM_ATTEMPTS |
100 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
REQID_SIZE |
32 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
NO_TRACE |
"No Trace" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_FORMAT |
"[%1$tF %1$tT %1$tz] [%4$s] %3$s: %5$s %6$s %n" |
public static final java.lang.String |
FORMAT_PROP_KEY |
"java.util.logging.SimpleFormatter.format" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
THREAD_GATEWAY_NAME |
"GatewayThread" |
public static final java.lang.String |
THREAD_SLAVE_NAME |
"SlaveThread" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
INTEGRATION_TEST_CONTROL_STREAM_ID |
"__integration_test_control_stream_id" |
public static final java.lang.String |
INTEGRATION_TEST_MOCK_MESSAGE_ID |
"__integration_test_mock_message_id" |
public static final java.lang.String |
INTEGRATION_TEST_TERMINAL |
"__integration_test_mock_terminal" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
METRICS_SINKS_TMASTER_METRICS |
"tmaster-metrics-type" |
public static final java.lang.String |
METRICS_SINKS_TMASTER_SINK |
"tmaster-sink" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CONFIG_SINK_PATH |
"../../../../../../../../../heron/config/src/yaml/conf/examples/metrics_sinks.yaml" |
public static final java.lang.String |
CONFIG_SYSTEM_PATH |
"../../../../../../../../../heron/config/src/yaml/conf/examples/heron_internals.yaml" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CONFIG_KEY_CLASSNAME |
"class" |
public static final java.lang.String |
CONFIG_KEY_FLUSH_FREQUENCY_MS |
"flush-frequency-ms" |
public static final java.lang.String |
CONFIG_KEY_METRICS_SINKS |
"sinks" |
public static final java.lang.String |
CONFIG_KEY_SINK_RESTART_ATTEMPTS |
"sink-restart-attempts" |
public static final int |
DEFAULT_SINK_RESTART_ATTEMPTS |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
BOLT_NAME |
"bolt" |
protected static final int |
DEFAULT_CONTAINER_PADDING |
10 |
protected static final java.lang.String |
SPOUT_NAME |
"spout" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
TOPOLOGY_NAME_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CONTAINER_INDEX_FIELD_NUMBER |
2 |
public static final int |
TOPOLOGY_NAME_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HTTP_ENDPOINT_FIELD_NUMBER |
2 |
public static final int |
JOB_PAGE_LINK_FIELD_NUMBER |
3 |
public static final int |
TOPOLOGY_NAME_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
STATUS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CURRENTPACKINGPLAN_FIELD_NUMBER |
1 |
public static final int |
PROPOSEDPACKINGPLAN_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PPLAN_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NEW_PPLAN_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
INSTANCE_FIELD_NUMBER |
1 |
public static final int |
TOPOLOGY_ID_FIELD_NUMBER |
3 |
public static final int |
TOPOLOGY_NAME_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PPLAN_FIELD_NUMBER |
2 |
public static final int |
STATUS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MESSAGE_ID_FIELD_NUMBER |
4 |
public static final int |
STMGR_FIELD_NUMBER |
3 |
public static final int |
TOPOLOGY_ID_FIELD_NUMBER |
2 |
public static final int |
TOPOLOGY_NAME_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MESSAGE_ID_FIELD_NUMBER |
4 |
public static final int |
STMGR_FIELD_NUMBER |
3 |
public static final int |
TOPOLOGY_ID_FIELD_NUMBER |
2 |
public static final int |
TOPOLOGY_NAME_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
STMGR_FIELD_NUMBER |
3 |
public static final int |
TOPOLOGY_ID_FIELD_NUMBER |
2 |
public static final int |
TOPOLOGY_NAME_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
STATUS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SET_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SET_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SET_FIELD_NUMBER |
2 |
public static final int |
TASK_ID_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SET_FIELD_NUMBER |
2 |
public static final int |
TASK_ID_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MESSAGE_FIELD_NUMBER |
2 |
public static final int |
STATUS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DUPLICATE_STRMGR_VALUE |
1002 |
public static final int |
INVALID_STMGR_VALUE |
1000 |
public static final int |
INVALID_TOPOLOGY_NAME_VALUE |
100 |
public static final int |
METRICSCACHELOCATION_ALREADY_EXISTS_VALUE |
2006 |
public static final int |
NOT_YET_IMPLEMENTED_VALUE |
103 |
public static final int |
NOTOK_VALUE |
2 |
public static final int |
OK_VALUE |
1 |
public static final int |
PATH_ALREADY_EXISTS_VALUE |
2001 |
public static final int |
PATH_DOES_NOT_EXIST_VALUE |
2000 |
public static final int |
STATE_CORRUPTED_VALUE |
2003 |
public static final int |
STATE_READ_ERROR_VALUE |
2004 |
public static final int |
STATE_WRITE_ERROR_VALUE |
2005 |
public static final int |
STMGR_DIDNT_REGISTER_VALUE |
1001 |
public static final int |
TMASTERLOCATION_ALREADY_EXISTS_VALUE |
2002 |
public static final int |
TOPOLOGY_ALREADY_ACTIVE_VALUE |
101 |
public static final int |
TOPOLOGY_ALREADY_DEACTIVE_VALUE |
102 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CLUSTER_FIELD_NUMBER |
5 |
public static final int |
ENVIRON_FIELD_NUMBER |
6 |
public static final int |
RELEASE_STATE_FIELD_NUMBER |
8 |
public static final int |
ROLE_FIELD_NUMBER |
7 |
public static final int |
SUBMISSION_TIME_FIELD_NUMBER |
3 |
public static final int |
SUBMISSION_USER_FIELD_NUMBER |
4 |
public static final int |
TOPOLOGY_ID_FIELD_NUMBER |
2 |
public static final int |
TOPOLOGY_NAME_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
RELEASE_TAG_FIELD_NUMBER |
2 |
public static final int |
RELEASE_USERNAME_FIELD_NUMBER |
1 |
public static final int |
RELEASE_VERSION_FIELD_NUMBER |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ACKEDTUPLE_FIELD_NUMBER |
2 |
public static final int |
ROOTS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ACKS_FIELD_NUMBER |
1 |
public static final int |
EMITS_FIELD_NUMBER |
3 |
public static final int |
FAILS_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEST_TASK_IDS_FIELD_NUMBER |
4 |
public static final int |
KEY_FIELD_NUMBER |
1 |
public static final int |
ROOTS_FIELD_NUMBER |
2 |
public static final int |
VALUES_FIELD_NUMBER |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
STREAM_FIELD_NUMBER |
1 |
public static final int |
TUPLES_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
STREAM_FIELD_NUMBER |
1 |
public static final int |
TUPLES_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CONTROL_FIELD_NUMBER |
2 |
public static final int |
DATA_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CONTROL_FIELD_NUMBER |
2 |
public static final int |
DATA_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
KEY_FIELD_NUMBER |
2 |
public static final int |
TASKID_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COUNT_FIELD_NUMBER |
4 |
public static final int |
FIRSTTIME_FIELD_NUMBER |
3 |
public static final int |
LASTTIME_FIELD_NUMBER |
2 |
public static final int |
LOGGING_FIELD_NUMBER |
5 |
public static final int |
STACKTRACE_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NAME_FIELD_NUMBER |
1 |
public static final int |
VALUE_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COMPONENT_NAME_FIELD_NUMBER |
3 |
public static final int |
HOSTNAME_FIELD_NUMBER |
1 |
public static final int |
INSTANCE_ID_FIELD_NUMBER |
4 |
public static final int |
INSTANCE_INDEX_FIELD_NUMBER |
5 |
public static final int |
PORT_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
EXCEPTIONS_FIELD_NUMBER |
2 |
public static final int |
METRICS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PUBLISHER_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
STATUS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
METRICSCACHE_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
TMASTER_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ID_FIELD_NUMBER |
1 |
public static final int |
INSTANCE_PLANS_FIELD_NUMBER |
2 |
public static final int |
REQUIREDRESOURCE_FIELD_NUMBER |
3 |
public static final int |
SCHEDULEDRESOURCE_FIELD_NUMBER |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COMPONENT_INDEX_FIELD_NUMBER |
3 |
public static final int |
COMPONENT_NAME_FIELD_NUMBER |
1 |
public static final int |
RESOURCE_FIELD_NUMBER |
4 |
public static final int |
TASK_ID_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CONTAINER_PLANS_FIELD_NUMBER |
2 |
public static final int |
ID_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CPU_FIELD_NUMBER |
1 |
public static final int |
DISK_FIELD_NUMBER |
3 |
public static final int |
RAM_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
INFO_FIELD_NUMBER |
3 |
public static final int |
INSTANCE_ID_FIELD_NUMBER |
1 |
public static final int |
STMGR_ID_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COMPONENT_INDEX_FIELD_NUMBER |
2 |
public static final int |
COMPONENT_NAME_FIELD_NUMBER |
3 |
public static final int |
PARAMS_FIELD_NUMBER |
4 |
public static final int |
TASK_ID_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
INSTANCES_FIELD_NUMBER |
3 |
public static final int |
STMGRS_FIELD_NUMBER |
2 |
public static final int |
TOPOLOGY_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CWD_FIELD_NUMBER |
5 |
public static final int |
DATA_PORT_FIELD_NUMBER |
3 |
public static final int |
HOST_NAME_FIELD_NUMBER |
2 |
public static final int |
ID_FIELD_NUMBER |
1 |
public static final int |
LOCAL_ENDPOINT_FIELD_NUMBER |
4 |
public static final int |
PID_FIELD_NUMBER |
6 |
public static final int |
SHELL_PORT_FIELD_NUMBER |
7 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ECHO_REQUEST_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ECHO_RESPONSE_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COMPONENT_NAME_FIELD_NUMBER |
1 |
public static final int |
INSTANCES_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
EXCEPTIONS_FIELD_NUMBER |
2 |
public static final int |
STATUS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COMPONENT_NAME_FIELD_NUMBER |
1 |
public static final int |
INSTANCE_ID_FIELD_NUMBER |
2 |
public static final int |
NAME_FIELD_NUMBER |
3 |
public static final int |
TIMESTAMP_FIELD_NUMBER |
5 |
public static final int |
VALUE_FIELD_NUMBER |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
END_FIELD_NUMBER |
2 |
public static final int |
START_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COMPONENT_NAME_FIELD_NUMBER |
1 |
public static final int |
EXPLICIT_INTERVAL_FIELD_NUMBER |
5 |
public static final int |
INSTANCE_ID_FIELD_NUMBER |
2 |
public static final int |
INTERVAL_FIELD_NUMBER |
4 |
public static final int |
METRIC_FIELD_NUMBER |
3 |
public static final int |
MINUTELY_FIELD_NUMBER |
6 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
INTERVAL_FIELD_NUMBER |
3 |
public static final int |
METRIC_FIELD_NUMBER |
2 |
public static final int |
STATUS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
INTERVAL_VALUES_FIELD_NUMBER |
3 |
public static final int |
NAME_FIELD_NUMBER |
1 |
public static final int |
VALUE_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
INTERVAL_FIELD_NUMBER |
2 |
public static final int |
VALUE_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
INSTANCE_ID_FIELD_NUMBER |
1 |
public static final int |
METRIC_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CONTROLLER_PORT_FIELD_NUMBER |
4 |
public static final int |
HOST_FIELD_NUMBER |
3 |
public static final int |
MASTER_PORT_FIELD_NUMBER |
5 |
public static final int |
STATS_PORT_FIELD_NUMBER |
6 |
public static final int |
TOPOLOGY_ID_FIELD_NUMBER |
2 |
public static final int |
TOPOLOGY_NAME_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
EXCEPTIONS_FIELD_NUMBER |
2 |
public static final int |
METRICS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HEARTBEAT_TIME_FIELD_NUMBER |
1 |
public static final int |
STATS_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
STATUS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
INSTANCES_FIELD_NUMBER |
2 |
public static final int |
STMGR_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PPLAN_FIELD_NUMBER |
2 |
public static final int |
STATUS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ABSENT_STMGRS_FIELD_NUMBER |
2 |
public static final int |
REGISTERED_STMGRS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COMPONENT_NAME_FIELD_NUMBER |
1 |
public static final int |
COUNT_FIELD_NUMBER |
7 |
public static final int |
FIRSTTIME_FIELD_NUMBER |
6 |
public static final int |
HOSTNAME_FIELD_NUMBER |
2 |
public static final int |
INSTANCE_ID_FIELD_NUMBER |
3 |
public static final int |
LASTTIME_FIELD_NUMBER |
5 |
public static final int |
LOGGING_FIELD_NUMBER |
8 |
public static final int |
STACKTRACE_FIELD_NUMBER |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CONTROLLER_PORT_FIELD_NUMBER |
4 |
public static final int |
HOST_FIELD_NUMBER |
3 |
public static final int |
MASTER_PORT_FIELD_NUMBER |
5 |
public static final int |
STATS_PORT_FIELD_NUMBER |
6 |
public static final int |
TOPOLOGY_ID_FIELD_NUMBER |
2 |
public static final int |
TOPOLOGY_NAME_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ACK_COUNT |
"ack-count" |
public static final java.lang.String |
ACTIVATE_COUNT |
"activate-count" |
public static final java.lang.String |
BUILD_TEST_HERON_INTERNALS_CONFIG_PATH |
"/__main__/heron/config/src/yaml/conf/test/test_heron_internals.yaml" |
public static final java.lang.String |
BUILD_TEST_SRCDIR |
"TEST_SRCDIR" |
public static final java.lang.String |
DEACTIVATE_COUNT |
"deactivate-count" |
public static final java.lang.String |
FAIL_COUNT |
"fail-count" |
public static final java.lang.String |
GATEWAY_METRICS |
"com.twitter.heron.metrics.GatewayMetrics" |
public static final java.lang.String |
HERON_SYSTEM_CONFIG |
"com.twitter.heron.common.config.SystemConfig" |
public static final java.lang.String |
PHYSICAL_PLAN_HELPER |
"com.twitter.heron.utility.PhysicalPlanHelper" |
public static final int |
QUEUE_BUFFER_SIZE |
128 |
public static final int |
RETRY_INTERVAL_MS |
1000 |
public static final int |
RETRY_TIMES |
10 |
public static final int |
TEST_WAIT_TIME_MS |
2000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
JOB_LINK_TEMPLATE |
"heron.scheduler.job.link.template" |
public static final java.lang.String |
JOB_TEMPLATE |
"heron.scheduler.job.template" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
APPS |
"apps" |
public static final java.lang.String |
CACHE |
"cache" |
public static final java.lang.String |
COMMAND |
"cmd" |
public static final java.lang.String |
CPU |
"cpus" |
public static final java.lang.String |
DISK |
"disk" |
public static final java.lang.String |
ENVIRONMENT |
"environment" |
public static final java.lang.String |
EXECUTABLE |
"executable" |
public static final java.lang.String |
EXTRACT |
"extract" |
public static final java.lang.String |
FETCH |
"fetch" |
public static final java.lang.String |
ID |
"id" |
public static final java.lang.String |
INSTANCES |
"instances" |
public static final java.lang.String |
JOB_LINK |
"/ui/#/group/%2F" |
public static final java.lang.String |
LABELS |
"labels" |
public static final java.lang.String |
MASTER_PORT |
"$PORT0" |
public static final java.lang.String |
MEMORY |
"mem" |
public static final java.lang.String |
METRICSMGR_PORT |
"$PORT4" |
public static final java.lang.String |
PORT |
"port" |
public static final java.lang.String |
PORT_DEFINITIONS |
"portDefinitions" |
public static final java.lang.String |
PORT_NAME |
"name" |
public static final java.lang.String |
PROTOCOL |
"protocol" |
public static final java.lang.String |
SCHEDULER_PORT |
"$PORT5" |
public static final java.lang.String |
SHELL_PORT |
"$PORT3" |
public static final java.lang.String |
TCP |
"tcp" |
public static final java.lang.String |
TMASTER_CONTROLLER_PORT |
"$PORT1" |
public static final java.lang.String |
TMASTER_STATS_PORT |
"$PORT2" |
public static final java.lang.String |
URI |
"uri" |
public static final java.lang.String |
USER |
"user" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
HERON_MARATHON_SCHEDULER_URI |
"heron.marathon.scheduler.uri" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
HERON_MESOS_FRAMEWORK_STAGING_TIMEOUT_MS |
"heron.mesos.framework.staging.timeout.ms" |
public static final java.lang.String |
HERON_MESOS_MASTER_URI |
"heron.mesos.master.uri" |
public static final java.lang.String |
HERON_MESOS_NATIVE_LIBRARY_PATH |
"heron.mesos.native.library.path" |
public static final java.lang.String |
HERON_MESOS_SCHEDULER_DRIVER_STOP_TIMEOUT_MS |
"heron.mesos.scheduler.driver.stop.timeout.ms" |
public static final java.lang.String |
SCHEDULER_WORKING_DIRECTORY |
"heron.scheduler.mesos.scheduler.working.directory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CPUS_RESOURCE_NAME |
"cpus" |
public static final java.lang.String |
DISK_RESOURCE_NAME |
"disk" |
public static final java.lang.String |
MEM_RESOURCE_NAME |
"mem" |
public static final java.lang.String |
PORT_RESOURCE_NAME |
"ports" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
TASK_ID_TEMPLATE |
"%s:%d" |
public static final java.lang.String |
TASK_NAME_TEMPLATE |
"container_%d_%d" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SLURM_JOB_ID |
"heron.scheduler.slurm.job.id" |
public static final java.lang.String |
SLURM_SHELL_SCRIPT |
"heron.scheduler.slurm.shell.script" |
public static final java.lang.String |
WORKING_DIRECTORY |
"heron.scheduler.local.working.directory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PORTS_REQUIRED_FOR_EXECUTOR |
8 |
public static final int |
PORTS_REQUIRED_FOR_SCHEDULER |
1 |
public static final java.lang.String |
SCHEDULER_COMMAND_LINE_PROPERTIES_OVERRIDE_OPTION |
"P" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CAPACITY |
5 |
public static final double |
CURRENT_SAMPLE_WEIGHT |
0.5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NUM_BUCKETS |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
TOPOLOGY_ID |
"topology-id" |
public static final java.lang.String |
TOPOLOGY_NAME |
"topology-name" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
N |
10 |
public static final int |
REPEAT |
10 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
serialVersionUID |
6599628617518713638L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
JSON_TYPE |
"application/json" |
public static final java.lang.String |
URL_ENCODE_TYPE |
"application/x-www-form-urlencoded" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
serialVersionUID |
2718487207462907715L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_FILENAME_EXTENSION |
".tar.gz" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CONNECTION_TIMEOUT_MS |
"heron.statemgr.zookeeper.connection.timeout.ms" |
public static final java.lang.String |
IS_INITIALIZE_TREE |
"heron.statemgr.zookeeper.is.initialize.tree" |
public static final java.lang.String |
IS_TUNNEL_NEEDED |
"heron.statemgr.is.tunnel.needed" |
public static final java.lang.String |
RETRY_COUNT |
"heron.statemgr.zookeeper.retry.count" |
public static final java.lang.String |
RETRY_INTERVAL_MS |
"heron.statemgr.zookeeper.retry.interval.ms" |
public static final java.lang.String |
SESSION_TIMEOUT_MS |
"heron.statemgr.zookeeper.session.timeout.ms" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
LOCAL_HOST |
"localhost" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
HERON_UPLOADER_S3_ACCESS_KEY |
"heron.uploader.s3.access_key" |
public static final java.lang.String |
HERON_UPLOADER_S3_AWS_PROFILE |
"heron.uploader.s3.aws_profile" |
public static final java.lang.String |
HERON_UPLOADER_S3_BUCKET |
"heron.uploader.s3.bucket" |
public static final java.lang.String |
HERON_UPLOADER_S3_PATH_PREFIX |
"heron.uploader.s3.path_prefix" |
public static final java.lang.String |
HERON_UPLOADER_S3_PROXY_URI |
"heron.uploader.s3.proxy_uri" |
public static final java.lang.String |
HERON_UPLOADER_S3_REGION |
"heron.uploader.s3.region" |
public static final java.lang.String |
HERON_UPLOADER_S3_SECRET_KEY |
"heron.uploader.s3.secret_key" |
public static final java.lang.String |
HERON_UPLOADER_S3_URI |
"heron.uploader.s3.uri" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
HERON_UPLOADER_SCP_CONNECTION |
"heron.uploader.scp.command.connection" |
public static final java.lang.String |
HERON_UPLOADER_SCP_DIR_PATH |
"heron.uploader.scp.dir.path" |
public static final java.lang.String |
HERON_UPLOADER_SCP_DIR_PATH_DEFAULT |
"${HOME}/heron/repository/${CLUSTER}/${ROLE}/${TOPOLOGY}" |
public static final java.lang.String |
HERON_UPLOADER_SCP_OPTIONS |
"heron.uploader.scp.command.options" |
public static final java.lang.String |
HERON_UPLOADER_SSH_CONNECTION |
"heron.uploader.ssh.command.connection" |
public static final java.lang.String |
HERON_UPLOADER_SSH_OPTIONS |
"heron.uploader.ssh.command.options" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
STORM_ZOOKEEPER_CONNECTION_TIMEOUT |
"storm.zookeeper.connection.timeout" |
public static final java.lang.String |
STORM_ZOOKEEPER_PORT |
"storm.zookeeper.port" |
public static final java.lang.String |
STORM_ZOOKEEPER_RETRY_INTERVAL |
"storm.zookeeper.retry.interval" |
public static final java.lang.String |
STORM_ZOOKEEPER_RETRY_TIMES |
"storm.zookeeper.retry.times" |
public static final java.lang.String |
STORM_ZOOKEEPER_SERVERS |
"storm.zookeeper.servers" |
public static final java.lang.String |
STORM_ZOOKEEPER_SESSION_TIMEOUT |
"storm.zookeeper.session.timeout" |
public static final java.lang.String |
STORMCOMPAT_TOPOLOGY_AUTO_TASK_HOOKS |
"stormcompat.topology.auto.task.hooks" |
public static final java.lang.String |
TOPOLOGY_ACKER_EXECUTORS |
"topology.acker.executors" |
public static final java.lang.String |
TOPOLOGY_AUTO_TASK_HOOKS |
"topology.auto.task.hooks" |
public static final java.lang.String |
TOPOLOGY_CAP_TICKET |
"topology.cap.ticket" |
public static final java.lang.String |
TOPOLOGY_DEBUG |
"topology.debug" |
public static final java.lang.String |
TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS |
"topology.enable.message.timeouts" |
public static final java.lang.String |
TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS |
"topology.error.throttle.interval.secs" |
public static final java.lang.String |
TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION |
"topology.fall.back.on.java.serialization" |
public static final java.lang.String |
TOPOLOGY_KRYO_DECORATORS |
"topology.kryo.decorators" |
public static final java.lang.String |
TOPOLOGY_KRYO_FACTORY |
"topology.kryo.factory" |
public static final java.lang.String |
TOPOLOGY_KRYO_REGISTER |
"topology.kryo.register" |
public static final java.lang.String |
TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL |
"topology.max.error.report.per.interval" |
public static final java.lang.String |
TOPOLOGY_MAX_SPOUT_PENDING |
"topology.max.spout.pending" |
public static final java.lang.String |
TOPOLOGY_MAX_TASK_PARALLELISM |
"topology.max.task.parallelism" |
public static final java.lang.String |
TOPOLOGY_MESSAGE_TIMEOUT_SECS |
"topology.message.timeout.secs" |
public static final java.lang.String |
TOPOLOGY_METRICS_CONSUMER_REGISTER |
"topology.metrics.consumer.register" |
public static final java.lang.String |
TOPOLOGY_NAME |
"topology.name" |
public static final java.lang.String |
TOPOLOGY_OPTIMIZE |
"topology.optimize" |
public static final java.lang.String |
TOPOLOGY_PROJECT_NAME |
"topology.project.name" |
public static final java.lang.String |
TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS |
"topology.skip.missing.kryo.registrations" |
public static final java.lang.String |
TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS |
"topology.sleep.spout.wait.strategy.time.ms" |
public static final java.lang.String |
TOPOLOGY_SPOUT_WAIT_STRATEGY |
"topology.spout.wait.strategy" |
public static final java.lang.String |
TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS |
"topology.state.synchronization.timeout.secs" |
public static final java.lang.String |
TOPOLOGY_STATS_SAMPLE_RATE |
"topology.stats.sample.rate" |
public static final java.lang.String |
TOPOLOGY_TASKS |
"topology.tasks" |
public static final java.lang.String |
TOPOLOGY_TEAM_EMAIL |
"topology.team.email" |
public static final java.lang.String |
TOPOLOGY_TEAM_NAME |
"topology.team.name" |
public static final java.lang.String |
TOPOLOGY_TICK_TUPLE_FREQ_SECS |
"topology.tick.tuple.freq.secs" |
public static final java.lang.String |
TOPOLOGY_TRANSACTIONAL_ID |
"topology.transactional.id" |
public static final java.lang.String |
TOPOLOGY_WORKER_CHILDOPTS |
"topology.worker.childopts" |
public static final java.lang.String |
TOPOLOGY_WORKERS |
"topology.workers" |
public static final java.lang.String |
TRANSACTIONAL_ZOOKEEPER_PORT |
"transactional.zookeeper.port" |
public static final java.lang.String |
TRANSACTIONAL_ZOOKEEPER_ROOT |
"transactional.zookeeper.root" |
public static final java.lang.String |
TRANSACTIONAL_ZOOKEEPER_SERVERS |
"transactional.zookeeper.servers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SYSTEM_COMPONENT_ID |
"__system" |
public static final java.lang.String |
SYSTEM_TICK_STREAM_ID |
"__tick" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
STRING_SCHEME_OFFSET |
"offset" |
public static final java.lang.String |
STRING_SCHEME_PARTITION_KEY |
"partition" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
STRING_SCHEME_KEY |
"str" |
public static final java.lang.String |
TOPIC_KEY |
"topic" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
STRING_SCHEME_KEY |
"str" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
TOPIC |
"test" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_STREAM_ID |
"default" |