Constant Field Values

Contents

• backtype.storm.*
• storm.trident.*

backtype.storm.*

backtype.storm.Config

Modifier and Type	Constant Field	Value
public static final String	DEV_ZOOKEEPER_PATH	"dev.zookeeper.path"
public static final String	DRPC_AUTHORIZER	"drpc.authorizer"
public static final String	DRPC_AUTHORIZER_ACL	"drpc.authorizer.acl"
public static final String	DRPC_AUTHORIZER_ACL_FILENAME	"drpc.authorizer.acl.filename"
public static final String	DRPC_AUTHORIZER_ACL_STRICT	"drpc.authorizer.acl.strict"
public static final String	DRPC_CHILDOPTS	"drpc.childopts"
public static final String	DRPC_HTTP_CREDS_PLUGIN	"drpc.http.creds.plugin"
public static final String	DRPC_HTTP_FILTER	"drpc.http.filter"
public static final String	DRPC_HTTP_FILTER_PARAMS	"drpc.http.filter.params"
public static final String	DRPC_HTTP_PORT	"drpc.http.port"
public static final String	DRPC_HTTPS_KEY_PASSWORD	"drpc.https.key.password"
public static final String	DRPC_HTTPS_KEYSTORE_PASSWORD	"drpc.https.keystore.password"
public static final String	DRPC_HTTPS_KEYSTORE_PATH	"drpc.https.keystore.path"
public static final String	DRPC_HTTPS_KEYSTORE_TYPE	"drpc.https.keystore.type"
public static final String	DRPC_HTTPS_NEED_CLIENT_AUTH	"drpc.https.need.client.auth"
public static final String	DRPC_HTTPS_PORT	"drpc.https.port"
public static final String	DRPC_HTTPS_TRUSTSTORE_PASSWORD	"drpc.https.truststore.password"
public static final String	DRPC_HTTPS_TRUSTSTORE_PATH	"drpc.https.truststore.path"
public static final String	DRPC_HTTPS_TRUSTSTORE_TYPE	"drpc.https.truststore.type"
public static final String	DRPC_HTTPS_WANT_CLIENT_AUTH	"drpc.https.want.client.auth"
public static final String	DRPC_INVOCATIONS_PORT	"drpc.invocations.port"
public static final String	DRPC_INVOCATIONS_THREADS	"drpc.invocations.threads"
public static final String	DRPC_INVOCATIONS_THRIFT_TRANSPORT_PLUGIN	"drpc.invocations.thrift.transport"
public static final String	DRPC_MAX_BUFFER_SIZE	"drpc.max_buffer_size"
public static final String	DRPC_PORT	"drpc.port"
public static final String	DRPC_QUEUE_SIZE	"drpc.queue.size"
public static final String	DRPC_REQUEST_TIMEOUT_SECS	"drpc.request.timeout.secs"
public static final String	DRPC_SERVERS	"drpc.servers"
public static final String	DRPC_THRIFT_TRANSPORT_PLUGIN	"drpc.thrift.transport"
public static final String	DRPC_WORKER_THREADS	"drpc.worker.threads"
public static final String	ISOLATION_SCHEDULER_MACHINES	"isolation.scheduler.machines"
public static final String	JAVA_LIBRARY_PATH	"java.library.path"
public static final String	LOGS_GROUPS	"logs.groups"
public static final String	LOGS_USERS	"logs.users"
public static final String	LOGVIEWER_APPENDER_NAME	"logviewer.appender.name"
public static final String	LOGVIEWER_CHILDOPTS	"logviewer.childopts"
public static final String	LOGVIEWER_CLEANUP_AGE_MINS	"logviewer.cleanup.age.mins"
public static final String	LOGVIEWER_CLEANUP_INTERVAL_SECS	"logviewer.cleanup.interval.secs"
public static final String	LOGVIEWER_PORT	"logviewer.port"
public static final String	MULTITENANT_SCHEDULER_USER_POOLS	"multitenant.scheduler.user.pools"
public static final String	NIMBUS_ADMINS	"nimbus.admins"
public static final String	NIMBUS_AUTHORIZER	"nimbus.authorizer"
public static final String	NIMBUS_AUTO_CRED_PLUGINS	"nimbus.autocredential.plugins.classes"
public static final String	NIMBUS_CHILDOPTS	"nimbus.childopts"
public static final String	NIMBUS_CLEANUP_INBOX_FREQ_SECS	"nimbus.cleanup.inbox.freq.secs"
public static final String	NIMBUS_CREDENTIAL_RENEW_FREQ_SECS	"nimbus.credential.renewers.freq.secs"
public static final String	NIMBUS_CREDENTIAL_RENEWERS	"nimbus.credential.renewers.classes"
public static final String	NIMBUS_EXECUTORS_PER_TOPOLOGY	"nimbus.executors.perTopology"
public static final String	NIMBUS_FILE_COPY_EXPIRATION_SECS	"nimbus.file.copy.expiration.secs"
public static final String	NIMBUS_GROUPS	"nimbus.groups"
public static final String	NIMBUS_HOST	"nimbus.host"
public static final String	NIMBUS_IMPERSONATION_ACL	"nimbus.impersonation.acl"
public static final String	NIMBUS_IMPERSONATION_AUTHORIZER	"nimbus.impersonation.authorizer"
public static final String	NIMBUS_INBOX_JAR_EXPIRATION_SECS	"nimbus.inbox.jar.expiration.secs"
public static final String	NIMBUS_MONITOR_FREQ_SECS	"nimbus.monitor.freq.secs"
public static final String	NIMBUS_REASSIGN	"nimbus.reassign"
public static final String	NIMBUS_SLOTS_PER_TOPOLOGY	"nimbus.slots.perTopology"
public static final String	NIMBUS_SUPERVISOR_TIMEOUT_SECS	"nimbus.supervisor.timeout.secs"
public static final String	NIMBUS_SUPERVISOR_USERS	"nimbus.supervisor.users"
public static final String	NIMBUS_TASK_LAUNCH_SECS	"nimbus.task.launch.secs"
public static final String	NIMBUS_TASK_TIMEOUT_SECS	"nimbus.task.timeout.secs"
public static final String	NIMBUS_THRIFT_MAX_BUFFER_SIZE	"nimbus.thrift.max_buffer_size"
public static final String	NIMBUS_THRIFT_PORT	"nimbus.thrift.port"
public static final String	NIMBUS_THRIFT_THREADS	"nimbus.thrift.threads"
public static final String	NIMBUS_THRIFT_TRANSPORT_PLUGIN	"nimbus.thrift.transport"
public static final String	NIMBUS_TOPOLOGY_VALIDATOR	"nimbus.topology.validator"
public static final String	NIMBUS_USERS	"nimbus.users"
public static final String	STORM_CLUSTER_MODE	"storm.cluster.mode"
public static final String	STORM_DO_AS_USER	"storm.doAsUser"
public static final String	STORM_GROUP_MAPPING_SERVICE_CACHE_DURATION_SECS	"storm.group.mapping.service.cache.duration.secs"
public static final String	STORM_GROUP_MAPPING_SERVICE_PROVIDER_PLUGIN	"storm.group.mapping.service"
public static final String	STORM_ID	"storm.id"
public static final String	STORM_LOCAL_DIR	"storm.local.dir"
public static final String	STORM_LOCAL_HOSTNAME	"storm.local.hostname"
public static final String	STORM_LOCAL_MODE_ZMQ	"storm.local.mode.zmq"
public static final String	STORM_MESSAGING_NETTY_AUTHENTICATION	"storm.messaging.netty.authentication"
public static final String	STORM_MESSAGING_NETTY_BUFFER_SIZE	"storm.messaging.netty.buffer_size"
public static final String	STORM_MESSAGING_NETTY_CLIENT_WORKER_THREADS	"storm.messaging.netty.client_worker_threads"
public static final String	STORM_MESSAGING_NETTY_MAX_RETRIES	"storm.messaging.netty.max_retries"
public static final String	STORM_MESSAGING_NETTY_MAX_SLEEP_MS	"storm.messaging.netty.max_wait_ms"
public static final String	STORM_MESSAGING_NETTY_MIN_SLEEP_MS	"storm.messaging.netty.min_wait_ms"
public static final String	STORM_MESSAGING_NETTY_SERVER_WORKER_THREADS	"storm.messaging.netty.server_worker_threads"
public static final String	STORM_MESSAGING_NETTY_SOCKET_BACKLOG	"storm.messaging.netty.socket.backlog"
public static final String	STORM_MESSAGING_TRANSPORT	"storm.messaging.transport"
public static final String	STORM_META_SERIALIZATION_DELEGATE	"storm.meta.serialization.delegate"
public static final String	STORM_NETTY_FLUSH_CHECK_INTERVAL_MS	"storm.messaging.netty.flush.check.interval.ms"
public static final String	STORM_NETTY_MESSAGE_BATCH_SIZE	"storm.messaging.netty.transfer.batch.size"
public static final String	STORM_NIMBUS_RETRY_INTERVAL	"storm.nimbus.retry.interval.millis"
public static final String	STORM_NIMBUS_RETRY_INTERVAL_CEILING	"storm.nimbus.retry.intervalceiling.millis"
public static final String	STORM_NIMBUS_RETRY_TIMES	"storm.nimbus.retry.times"
public static final String	STORM_PRINCIPAL_TO_LOCAL_PLUGIN	"storm.principal.tolocal"
public static final String	STORM_SCHEDULER	"storm.scheduler"
public static final String	STORM_THRIFT_TRANSPORT_PLUGIN	"storm.thrift.transport"
public static final String	STORM_ZOOKEEPER_AUTH_PAYLOAD	"storm.zookeeper.auth.payload"
public static final String	STORM_ZOOKEEPER_AUTH_SCHEME	"storm.zookeeper.auth.scheme"
public static final String	STORM_ZOOKEEPER_CONNECTION_TIMEOUT	"storm.zookeeper.connection.timeout"
public static final String	STORM_ZOOKEEPER_PORT	"storm.zookeeper.port"
public static final String	STORM_ZOOKEEPER_RETRY_INTERVAL	"storm.zookeeper.retry.interval"
public static final String	STORM_ZOOKEEPER_RETRY_INTERVAL_CEILING	"storm.zookeeper.retry.intervalceiling.millis"
public static final String	STORM_ZOOKEEPER_RETRY_TIMES	"storm.zookeeper.retry.times"
public static final String	STORM_ZOOKEEPER_ROOT	"storm.zookeeper.root"
public static final String	STORM_ZOOKEEPER_SERVERS	"storm.zookeeper.servers"
public static final String	STORM_ZOOKEEPER_SESSION_TIMEOUT	"storm.zookeeper.session.timeout"
public static final String	STORM_ZOOKEEPER_SUPERACL	"storm.zookeeper.superACL"
public static final String	STORM_ZOOKEEPER_TOPOLOGY_AUTH_PAYLOAD	"storm.zookeeper.topology.auth.payload"
public static final String	STORM_ZOOKEEPER_TOPOLOGY_AUTH_SCHEME	"storm.zookeeper.topology.auth.scheme"
public static final String	SUPERVISOR_CHILDOPTS	"supervisor.childopts"
public static final String	SUPERVISOR_ENABLE	"supervisor.enable"
public static final String	SUPERVISOR_HEARTBEAT_FREQUENCY_SECS	"supervisor.heartbeat.frequency.secs"
public static final String	SUPERVISOR_MONITOR_FREQUENCY_SECS	"supervisor.monitor.frequency.secs"
public static final String	SUPERVISOR_RUN_WORKER_AS_USER	"supervisor.run.worker.as.user"
public static final String	SUPERVISOR_SCHEDULER_META	"supervisor.scheduler.meta"
public static final String	SUPERVISOR_SLOTS_PORTS	"supervisor.slots.ports"
public static final String	SUPERVISOR_WORKER_LAUNCHER	"supervisor.worker.launcher"
public static final String	SUPERVISOR_WORKER_SHUTDOWN_SLEEP_SECS	"supervisor.worker.shutdown.sleep.secs"
public static final String	SUPERVISOR_WORKER_START_TIMEOUT_SECS	"supervisor.worker.start.timeout.secs"
public static final String	SUPERVISOR_WORKER_TIMEOUT_SECS	"supervisor.worker.timeout.secs"
public static final String	TASK_CREDENTIALS_POLL_SECS	"task.credentials.poll.secs"
public static final String	TASK_HEARTBEAT_FREQUENCY_SECS	"task.heartbeat.frequency.secs"
public static final String	TASK_REFRESH_POLL_SECS	"task.refresh.poll.secs"
public static final String	TOPOLOGY_ACKER_EXECUTORS	"topology.acker.executors"
public static final String	TOPOLOGY_AUTO_CREDENTIALS	"topology.auto-credentials"
public static final String	TOPOLOGY_AUTO_TASK_HOOKS	"topology.auto.task.hooks"
public static final String	TOPOLOGY_BOLTS_OUTGOING_OVERFLOW_BUFFER_ENABLE	"topology.bolts.outgoing.overflow.buffer.enable"
public static final String	TOPOLOGY_BUILTIN_METRICS_BUCKET_SIZE_SECS	"topology.builtin.metrics.bucket.size.secs"
public static final String	TOPOLOGY_CLASSPATH	"topology.classpath"
public static final String	TOPOLOGY_DEBUG	"topology.debug"
public static final String	TOPOLOGY_DISRUPTOR_WAIT_STRATEGY	"topology.disruptor.wait.strategy"
public static final String	TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS	"topology.enable.message.timeouts"
public static final String	TOPOLOGY_ENVIRONMENT	"topology.environment"
public static final String	TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS	"topology.error.throttle.interval.secs"
public static final String	TOPOLOGY_EXECUTOR_RECEIVE_BUFFER_SIZE	"topology.executor.receive.buffer.size"
public static final String	TOPOLOGY_EXECUTOR_SEND_BUFFER_SIZE	"topology.executor.send.buffer.size"
public static final String	TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION	"topology.fall.back.on.java.serialization"
public static final String	TOPOLOGY_GROUPS	"topology.groups"
public static final String	TOPOLOGY_ISOLATED_MACHINES	"topology.isolate.machines"
public static final String	TOPOLOGY_KRYO_DECORATORS	"topology.kryo.decorators"
public static final String	TOPOLOGY_KRYO_FACTORY	"topology.kryo.factory"
public static final String	TOPOLOGY_KRYO_REGISTER	"topology.kryo.register"
public static final String	TOPOLOGY_LOGGING_SENSITIVITY	"topology.logging.sensitivity"
public static final String	TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL	"topology.max.error.report.per.interval"
public static final String	TOPOLOGY_MAX_SPOUT_PENDING	"topology.max.spout.pending"
public static final String	TOPOLOGY_MAX_TASK_PARALLELISM	"topology.max.task.parallelism"
public static final String	TOPOLOGY_MESSAGE_TIMEOUT_SECS	"topology.message.timeout.secs"
public static final String	TOPOLOGY_METRICS_CONSUMER_REGISTER	"topology.metrics.consumer.register"
public static final String	TOPOLOGY_MULTILANG_SERIALIZER	"topology.multilang.serializer"
public static final String	TOPOLOGY_NAME	"topology.name"
public static final String	TOPOLOGY_SHELLBOLT_MAX_PENDING	"topology.shellbolt.max.pending"
public static final String	TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS	"topology.skip.missing.kryo.registrations"
public static final String	TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS	"topology.sleep.spout.wait.strategy.time.ms"
public static final String	TOPOLOGY_SPOUT_WAIT_STRATEGY	"topology.spout.wait.strategy"
public static final String	TOPOLOGY_SPREAD_COMPONENTS	"topology.spread.components"
public static final String	TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS	"topology.state.synchronization.timeout.secs"
public static final String	TOPOLOGY_STATS_SAMPLE_RATE	"topology.stats.sample.rate"
public static final String	TOPOLOGY_SUBMITTER_PRINCIPAL	"topology.submitter.principal"
public static final String	TOPOLOGY_SUBMITTER_USER	"topology.submitter.user"
public static final String	TOPOLOGY_TASKS	"topology.tasks"
public static final String	TOPOLOGY_TESTING_ALWAYS_TRY_SERIALIZE	"topology.testing.always.try.serialize"
public static final String	TOPOLOGY_TICK_TUPLE_FREQ_SECS	"topology.tick.tuple.freq.secs"
public static final String	TOPOLOGY_TRANSACTIONAL_ID	"topology.transactional.id"
public static final String	TOPOLOGY_TRANSFER_BUFFER_SIZE	"topology.transfer.buffer.size"
public static final String	TOPOLOGY_TRIDENT_BATCH_EMIT_INTERVAL_MILLIS	"topology.trident.batch.emit.interval.millis"
public static final String	TOPOLOGY_TUPLE_SERIALIZER	"topology.tuple.serializer"
public static final String	TOPOLOGY_USERS	"topology.users"
public static final String	TOPOLOGY_WORKER_CHILDOPTS	"topology.worker.childopts"
public static final String	TOPOLOGY_WORKER_GC_CHILDOPTS	"topology.worker.gc.childopts"
public static final String	TOPOLOGY_WORKER_SHARED_THREAD_POOL_SIZE	"topology.worker.shared.thread.pool.size"
public static final String	TOPOLOGY_WORKERS	"topology.workers"
public static final String	TRANSACTIONAL_ZOOKEEPER_PORT	"transactional.zookeeper.port"
public static final String	TRANSACTIONAL_ZOOKEEPER_ROOT	"transactional.zookeeper.root"
public static final String	TRANSACTIONAL_ZOOKEEPER_SERVERS	"transactional.zookeeper.servers"
public static final String	UI_CHILDOPTS	"ui.childopts"
public static final String	UI_FILTER	"ui.filter"
public static final String	UI_FILTER_PARAMS	"ui.filter.params"
public static final String	UI_HEADER_BUFFER_BYTES	"ui.header.buffer.bytes"
public static final String	UI_HOST	"ui.host"
public static final String	UI_HTTP_CREDS_PLUGIN	"ui.http.creds.plugin"
public static final String	UI_HTTPS_KEY_PASSWORD	"ui.https.key.password"
public static final String	UI_HTTPS_KEYSTORE_PASSWORD	"ui.https.keystore.password"
public static final String	UI_HTTPS_KEYSTORE_PATH	"ui.https.keystore.path"
public static final String	UI_HTTPS_KEYSTORE_TYPE	"ui.https.keystore.type"
public static final String	UI_HTTPS_NEED_CLIENT_AUTH	"ui.https.need.client.auth"
public static final String	UI_HTTPS_PORT	"ui.https.port"
public static final String	UI_HTTPS_TRUSTSTORE_PASSWORD	"ui.https.truststore.password"
public static final String	UI_HTTPS_TRUSTSTORE_PATH	"ui.https.truststore.path"
public static final String	UI_HTTPS_TRUSTSTORE_TYPE	"ui.https.truststore.type"
public static final String	UI_HTTPS_WANT_CLIENT_AUTH	"ui.https.want.client.auth"
public static final String	UI_PORT	"ui.port"
public static final String	WORKER_CHILDOPTS	"worker.childopts"
public static final String	WORKER_GC_CHILDOPTS	"worker.gc.childopts"
public static final String	WORKER_HEARTBEAT_FREQUENCY_SECS	"worker.heartbeat.frequency.secs"
public static final String	WORKER_RECEIVER_THREAD_COUNT	"topology.worker.receiver.thread.count"
public static final String	ZMQ_HWM	"zmq.hwm"
public static final String	ZMQ_LINGER_MILLIS	"zmq.linger.millis"
public static final String	ZMQ_THREADS	"zmq.threads"

backtype.storm.Constants

Modifier and Type	Constant Field	Value
public static final String	CREDENTIALS_CHANGED_STREAM_ID	"__credentials"
public static final String	METRICS_COMPONENT_ID_PREFIX	"__metrics"
public static final String	METRICS_STREAM_ID	"__metrics"
public static final String	METRICS_TICK_STREAM_ID	"__metrics_tick"
public static final String	SYSTEM_COMPONENT_ID	"__system"
public static final long	SYSTEM_TASK_ID	-1L
public static final String	SYSTEM_TICK_STREAM_ID	"__tick"

backtype.storm.drpc.PrepareRequest

Modifier and Type	Constant Field	Value
public static final String	ARGS_STREAM	"default"
public static final String	ID_STREAM	"id"
public static final String	RETURN_STREAM	"ret"

backtype.storm.security.auth.AuthUtils

Modifier and Type	Constant Field	Value
public static final String	LOGIN_CONTEXT_CLIENT	"StormClient"
public static final String	LOGIN_CONTEXT_SERVER	"StormServer"
public static final String	SERVICE	"storm_thrift_server"

backtype.storm.security.auth.authorizer.DRPCAuthorizerBase

Modifier and Type	Constant Field	Value
public static final String	FUNCTION_NAME	"function.name"

backtype.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer

Modifier and Type	Constant Field	Value
public static final String	CLIENT_USERS_KEY	"client.users"
public static final String	FUNCTION_KEY	"function.name"
public static final String	INVOCATION_USER_KEY	"invocation.user"

backtype.storm.security.auth.authorizer.ImpersonationAuthorizer

Modifier and Type	Constant Field	Value
protected static final String	WILD_CARD	"*"

backtype.storm.security.auth.digest.DigestSaslTransportPlugin

Modifier and Type	Constant Field	Value
public static final String	DIGEST	"DIGEST-MD5"

backtype.storm.security.auth.kerberos.KerberosSaslTransportPlugin

Modifier and Type	Constant Field	Value
public static final String	KERBEROS	"GSSAPI"

backtype.storm.task.ShellBolt

Modifier and Type	Constant Field	Value
public static final String	HEARTBEAT_STREAM_ID	"__heartbeat"

backtype.storm.task.WorkerTopologyContext

Modifier and Type	Constant Field	Value
public static final String	SHARED_EXECUTOR	"executor"

backtype.storm.utils.Utils

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_STREAM_ID	"default"

storm.trident.*

storm.trident.spout.RichSpoutBatchExecutor

Modifier and Type	Constant Field	Value
public static final String	MAX_BATCH_SIZE_CONF	"topology.spout.max.batch.size"

storm.trident.topology.MasterBatchCoordinator

Modifier and Type	Constant Field	Value
public static final String	BATCH_STREAM_ID	"$batch"
public static final String	COMMIT_STREAM_ID	"$commit"
public static final long	INIT_TXID	1L
public static final String	SUCCESS_STREAM_ID	"$success"