Constant Field Values

Contents

• backtype.storm.*
• org.apache.*
• storm.kafka.*
• storm.starter.*
• 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_HTTPS_KEY_PASSWORD	"logviewer.https.key.password"
public static final String	LOGVIEWER_HTTPS_KEYSTORE_PASSWORD	"logviewer.https.keystore.password"
public static final String	LOGVIEWER_HTTPS_KEYSTORE_PATH	"logviewer.https.keystore.path"
public static final String	LOGVIEWER_HTTPS_KEYSTORE_TYPE	"logviewer.https.keystore.type"
public static final String	LOGVIEWER_HTTPS_NEED_CLIENT_AUTH	"logviewer.https.need.client.auth"
public static final String	LOGVIEWER_HTTPS_PORT	"logviewer.https.port"
public static final String	LOGVIEWER_HTTPS_TRUSTSTORE_PASSWORD	"logviewer.https.truststore.password"
public static final String	LOGVIEWER_HTTPS_TRUSTSTORE_PATH	"logviewer.https.truststore.path"
public static final String	LOGVIEWER_HTTPS_TRUSTSTORE_TYPE	"logviewer.https.truststore.type"
public static final String	LOGVIEWER_HTTPS_WANT_CLIENT_AUTH	"logviewer.https.want.client.auth"
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_DISRUPTOR_WAIT_TIMEOUT_MILLIS	"topology.disruptor.wait.timeout.millis"
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"

org.apache.*

org.apache.storm.eventhubs.spout.EventHubSpoutConfig

Modifier and Type	Constant Field	Value
public static final String	EH_SERVICE_FQDN_SUFFIX	"servicebus.windows.net"

org.apache.storm.eventhubs.spout.FieldConstants

Modifier and Type	Constant Field	Value
public static final String	Message	"message"
public static final String	Offset	"offset"
public static final String	PartitionKey	"partitionKey"

org.apache.storm.flux.model.TopologySourceDef

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_METHOD_NAME	"getTopology"

org.apache.storm.hbase.security.AutoHBase

Modifier and Type	Constant Field	Value
public static final String	HBASE_CREDENTIALS	"HBASE_CREDENTIALS"
public static final String	HBASE_KEYTAB_FILE_KEY	"hbase.keytab.file"
public static final String	HBASE_PRINCIPAL_KEY	"hbase.kerberos.principal"

org.apache.storm.hbase.security.HBaseSecurityUtil

Modifier and Type	Constant Field	Value
public static final String	STORM_KEYTAB_FILE_KEY	"storm.keytab.file"
public static final String	STORM_USER_NAME_KEY	"storm.kerberos.principal"

org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_FIELD_DELIMITER	","
public static final String	DEFAULT_RECORD_DELIMITER	"\n"

org.apache.storm.hdfs.common.security.AutoHDFS

Modifier and Type	Constant Field	Value
public static final String	HDFS_CREDENTIALS	"HDFS_CREDENTIALS"
public static final String	TOPOLOGY_HDFS_URI	"topology.hdfs.uri"

org.apache.storm.hdfs.common.security.HdfsSecurityUtil

Modifier and Type	Constant Field	Value
public static final String	STORM_KEYTAB_FILE_KEY	"hdfs.keytab.file"
public static final String	STORM_USER_NAME_KEY	"hdfs.kerberos.principal"

org.apache.storm.hdfs.trident.format.DelimitedRecordFormat

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_FIELD_DELIMITER	","
public static final String	DEFAULT_RECORD_DELIMITER	"\n"

org.apache.storm.redis.common.config.JedisPoolConfig

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_HOST	"127.0.0.1"

storm.kafka.*

storm.kafka.StringScheme

Modifier and Type	Constant Field	Value
public static final String	STRING_SCHEME_KEY	"str"

storm.kafka.bolt.KafkaBolt<K,V>

Modifier and Type	Constant Field	Value
public static final String	KAFKA_BROKER_PROPERTIES	"kafka.broker.properties"
public static final String	TOPIC	"topic"

storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper<K,V>

Modifier and Type	Constant Field	Value
public static final String	BOLT_KEY	"key"
public static final String	BOLT_MESSAGE	"message"

storm.kafka.trident.TridentKafkaState

Modifier and Type	Constant Field	Value
public static final String	KAFKA_BROKER_PROPERTIES	"kafka.broker.properties"

storm.starter.*

storm.starter.TransactionalGlobalCount

Modifier and Type	Constant Field	Value
public static final String	GLOBAL_COUNT_KEY	"GLOBAL-COUNT"
public static final int	PARTITION_TAKE_PER_BATCH	3

storm.starter.TransactionalWords

Modifier and Type	Constant Field	Value
public static final int	BUCKET_SIZE	10
public static final int	PARTITION_TAKE_PER_BATCH	3

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"