Modifier and Type | Constant Field | Value |
---|---|---|
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" |
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_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_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 |
CONFIG_FIELD_NUMBER |
3 |
public static final int |
JAVA_CLASS_NAME_FIELD_NUMBER |
2 |
public static final int |
JAVA_OBJECT_FIELD_NUMBER |
4 |
public static final int |
NAME_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
KVS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
JAVA_SERIALIZED_VALUE_FIELD_NUMBER |
3 |
public static final int |
KEY_FIELD_NUMBER |
1 |
public static final int |
VALUE_FIELD_NUMBER |
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_JAVA_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 |
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 java.lang.String |
ENVIRON_KEY |
"environ" |
public static final java.lang.String |
GROUP_KEY |
"group" |
public static final java.lang.String |
LAUNCHER_CLASS_KEY |
"heron.launcher.class" |
public static final java.lang.String |
ROLE_KEY |
"role" |
public static final java.lang.String |
TEST_DATA_PATH |
"/heron/common/tests/java/com/twitter/heron/common/config/testdata" |
public static final java.lang.String |
USER_KEY |
"user" |
public static final java.lang.String |
VERSION_KEY |
"version" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
HERON_LOGGING_DIRECTORY |
"heron.logging.directory" |
public static final java.lang.String |
HERON_LOGGING_ERR_THRESHOLD |
"heron.logging.err.threshold" |
public static final java.lang.String |
HERON_LOGGING_MAXIMUM_FILES |
"heron.logging.maximum.files" |
public static final java.lang.String |
HERON_LOGGING_MAXIMUM_SIZE_MB |
"heron.logging.maximum.size.mb" |
public static final java.lang.String |
HERON_METRICS_EXPORT_INTERVAL_SEC |
"heron.metrics.export.interval.sec" |
public static final java.lang.String |
INSTANCE_ACK_BATCH_TIME_MS |
"heron.instance.ack.batch.time.ms" |
public static final java.lang.String |
INSTANCE_ACKNOWLEDGEMENT_NBUCKETS |
"heron.instance.acknowledgement.nbuckets" |
public static final java.lang.String |
INSTANCE_EMIT_BATCH_SIZE_BYTES |
"heron.instance.emit.batch.size.bytes" |
public static final java.lang.String |
INSTANCE_EMIT_BATCH_TIME_MS |
"heron.instance.emit.batch.time.ms" |
public static final java.lang.String |
INSTANCE_EXECUTE_BATCH_SIZE_BYTES |
"heron.instance.execute.batch.size.bytes" |
public static final java.lang.String |
INSTANCE_EXECUTE_BATCH_TIME_MS |
"heron.instance.execute.batch.time.ms" |
public static final java.lang.String |
INSTANCE_FORCE_EXIT_TIMEOUT_MS |
"heron.instance.force.exit.timeout.ms" |
public static final java.lang.String |
INSTANCE_INTERNAL_BOLT_READ_QUEUE_CAPACITY |
"heron.instance.internal.bolt.read.queue.capacity" |
public static final java.lang.String |
INSTANCE_INTERNAL_BOLT_WRITE_QUEUE_CAPACITY |
"heron.instance.internal.bolt.write.queue.capacity" |
public static final java.lang.String |
INSTANCE_INTERNAL_METRICS_WRITE_QUEUE_CAPACITY |
"heron.instance.internal.metrics.write.queue.capacity" |
public static final java.lang.String |
INSTANCE_INTERNAL_SPOUT_READ_QUEUE_CAPACITY |
"heron.instance.internal.spout.read.queue.capacity" |
public static final java.lang.String |
INSTANCE_INTERNAL_SPOUT_WRITE_QUEUE_CAPACITY |
"heron.instance.internal.spout.write.queue.capacity" |
public static final java.lang.String |
INSTANCE_METRICS_SYSTEM_SAMPLE_INTERVAL_SEC |
"heron.instance.metrics.system.sample.interval.sec" |
public static final java.lang.String |
INSTANCE_NETWORK_OPTIONS_SOCKET_RECEIVED_BUFFER_SIZE_BYTES |
"heron.instance.network.options.socket.received.buffer.size.bytes" |
public static final java.lang.String |
INSTANCE_NETWORK_OPTIONS_SOCKET_SEND_BUFFER_SIZE_BYTES |
"heron.instance.network.options.socket.send.buffer.size.bytes" |
public static final java.lang.String |
INSTANCE_NETWORK_READ_BATCH_SIZE_BYTES |
"heron.instance.network.read.batch.size.bytes" |
public static final java.lang.String |
INSTANCE_NETWORK_READ_BATCH_TIME_MS |
"heron.instance.network.read.batch.time.ms" |
public static final java.lang.String |
INSTANCE_NETWORK_WRITE_BATCH_SIZE_BYTES |
"heron.instance.network.write.batch.size.bytes" |
public static final java.lang.String |
INSTANCE_NETWORK_WRITE_BATCH_TIME_MS |
"heron.instance.network.write.batch.time.ms" |
public static final java.lang.String |
INSTANCE_RECONNECT_METRICSMGR_INTERVAL_SEC |
"heron.instance.reconnect.metricsmgr.interval.sec" |
public static final java.lang.String |
INSTANCE_RECONNECT_STREAMMGR_INTERVAL_SEC |
"heron.instance.reconnect.streammgr.interval.sec" |
public static final java.lang.String |
INSTANCE_SET_CONTROL_TUPLE_CAPACITY |
"heron.instance.set.control.tuple.capacity" |
public static final java.lang.String |
INSTANCE_SET_DATA_TUPLE_CAPACITY |
"heron.instance.set.data.tuple.capacity" |
public static final java.lang.String |
INSTANCE_SLAVE_FETCH_PPLAN_INTERVAL_SEC |
"heron.instance.slave.fetch.pplan.interval.sec" |
public static final java.lang.String |
INSTANCE_STATE_CHECK_INTERVAL_SEC |
"heron.instance.state.check.interval.sec" |
public static final java.lang.String |
INSTANCE_TUNING_CURRENT_SAMPLE_WEIGHT |
"heron.instance.tuning.current.sample.weight" |
public static final java.lang.String |
INSTANCE_TUNING_EXPECTED_BOLT_READ_QUEUE_SIZE |
"heron.instance.tuning.expected.bolt.read.queue.size" |
public static final java.lang.String |
INSTANCE_TUNING_EXPECTED_BOLT_WRITE_QUEUE_SIZE |
"heron.instance.tuning.expected.bolt.write.queue.size" |
public static final java.lang.String |
INSTANCE_TUNING_EXPECTED_METRICS_WRITE_QUEUE_SIZE |
"heron.instance.tuning.expected.metrics.write.queue.size" |
public static final java.lang.String |
INSTANCE_TUNING_EXPECTED_SPOUT_READ_QUEUE_SIZE |
"heron.instance.tuning.expected.spout.read.queue.size" |
public static final java.lang.String |
INSTANCE_TUNING_EXPECTED_SPOUT_WRITE_QUEUE_SIZE |
"heron.instance.tuning.expected.spout.write.queue.size" |
public static final java.lang.String |
INSTANCE_TUNING_INTERVAL_MS |
"heron.instance.tuning.interval.ms" |
public static final java.lang.String |
METRICSMGR_NETWORK_OPTIONS_SOCKET_RECEIVED_BUFFER_SIZE_BYTES |
"heron.metricsmgr.network.options.socket.received.buffer.size.bytes" |
public static final java.lang.String |
METRICSMGR_NETWORK_OPTIONS_SOCKET_SEND_BUFFER_SIZE_BYTES |
"heron.metricsmgr.network.options.socket.send.buffer.size.bytes" |
public static final java.lang.String |
METRICSMGR_NETWORK_READ_BATCH_SIZE_BYTES |
"heron.metricsmgr.network.read.batch.size.bytes" |
public static final java.lang.String |
METRICSMGR_NETWORK_READ_BATCH_TIME_MS |
"heron.metricsmgr.network.read.batch.time.ms" |
public static final java.lang.String |
METRICSMGR_NETWORK_WRITE_BATCH_SIZE_BYTES |
"heron.metricsmgr.network.write.batch.size.bytes" |
public static final java.lang.String |
METRICSMGR_NETWORK_WRITE_BATCH_TIME_MS |
"heron.metricsmgr.network.write.batch.time.ms" |
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] %3$s %4$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 |
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 |
---|---|---|
public static final double |
DEFAULT_CPU_PADDING_PER_CONTAINER |
1.0 |
public static final long |
DEFAULT_DISK_PADDING_PER_CONTAINER |
12884901888L |
public static final long |
DEFAULT_RAM_PADDING_PER_CONTAINER |
2147483648L |
public static final long |
MIN_RAM_PER_INSTANCE |
201326592L |
public static final java.lang.String |
NOT_SPECIFIED_NUMBER_VALUE |
"-1" |
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 |
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 |
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 |
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 |
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 |
TMASTER_FIELD_NUMBER |
1 |
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 |
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 |
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 |
"/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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULTS_YAML |
"com/twitter/heron/scheduler/local/defaults.yaml" |
public static final java.lang.String |
KEYS_YAML |
"com/twitter/heron/scheduler/local/keys.yaml" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
KILL_REQUEST_CONTEXT |
"/kill" |
public static final java.lang.String |
RESTART_REQUEST_CONTEXT |
"/restart" |
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 |
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 java.lang.String |
DEFAULTS_YAML |
"com/twitter/heron/spi/common/defaults.yaml" |
public static final long |
GB |
1073741824L |
public static final java.lang.String |
KEYS_YAML |
"com/twitter/heron/spi/common/keys.yaml" |
public static final long |
MB |
1048576L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CONTENT_LENGTH |
"Content-Length" |
public static final java.lang.String |
CONTENT_TYPE |
"Content-Type" |
public static final java.lang.String |
LOCAL_HOST |
"localhost" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PORTS_REQUIRED_FOR_EXECUTOR |
6 |
public static final int |
PORTS_REQUIRED_FOR_SCHEDULER |
1 |
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" |
public static final java.lang.String |
TUNNEL_CONNECTION_RETRY_COUNT |
"heron.statemgr.tunnel.connection.retry.count" |
public static final java.lang.String |
TUNNEL_CONNECTION_TIMEOUT_MS |
"heron.statemgr.tunnel.connection.timeout.ms" |
public static final java.lang.String |
TUNNEL_HOST |
"heron.statemgr.tunnel.host" |
public static final java.lang.String |
TUNNEL_RETRY_INTERVAL_MS |
"heron.statemgr.tunnel.retry.interval.ms" |
public static final java.lang.String |
TUNNEL_VERIFY_COUNT |
"heron.statemgr.tunnel.verify.count" |
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_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_SECRET_KEY |
"heron.uploader.s3.secret_key" |
Modifier and Type | Constant Field | Value |
---|---|---|
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_STREAM_ID |
"default" |