Constant Field Values

Contents

• org.apache.*
• storm.starter.*

org.apache.*

org.apache.storm.Config

Modifier and Type	Constant Field	Value
public static final String	BACKPRESSURE_DISRUPTOR_HIGH_WATERMARK	"backpressure.disruptor.high.watermark"
public static final String	BACKPRESSURE_DISRUPTOR_LOW_WATERMARK	"backpressure.disruptor.low.watermark"
public static final String	BLOBSTORE_CLEANUP_ENABLE	"blobstore.cleanup.enable"
public static final String	BLOBSTORE_DIR	"blobstore.dir"
public static final String	BLOBSTORE_HDFS_KEYTAB	"blobstore.hdfs.keytab"
public static final String	BLOBSTORE_HDFS_PRINCIPAL	"blobstore.hdfs.principal"
public static final String	BLOBSTORE_SUPERUSER	"blobstore.superuser"
public static final String	CLIENT_BLOBSTORE	"client.blobstore.class"
public static final String	CLIENT_JAR_TRANSFORMER	"client.jartransformer.class"
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_MAX_PER_WORKER_LOGS_SIZE_MB	"logviewer.max.per.worker.logs.size.mb"
public static final String	LOGVIEWER_MAX_SUM_WORKER_LOGS_SIZE_MB	"logviewer.max.sum.worker.logs.size.mb"
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_BLOBSTORE	"nimbus.blobstore.class"
public static final String	NIMBUS_BLOBSTORE_EXPIRATION_SECS	"nimbus.blobstore.expiration.secs"
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_CODE_SYNC_FREQ_SECS	"nimbus.code.sync.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_DAEMON_USER	"nimbus.daemon.user"
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_QUEUE_SIZE	"nimbus.queue.size"
public static final String	NIMBUS_SEEDS	"nimbus.seeds"
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_ACTION_NOTIFIER_PLUGIN	"nimbus.topology.action.notifier.plugin.class"
public static final String	NIMBUS_TOPOLOGY_VALIDATOR	"nimbus.topology.validator"
public static final String	NIMBUS_USERS	"nimbus.users"
public static final String	PACEMAKER_AUTH_METHOD	"pacemaker.auth.method"
public static final String	PACEMAKER_CHILDOPTS	"pacemaker.childopts"
public static final String	PACEMAKER_MAX_THREADS	"pacemaker.max.threads"
public static final String	PACEMAKER_PORT	"pacemaker.port"
public static final String	PACEMAKER_SERVERS	"pacemaker.servers"
public static final String	RESOURCE_AWARE_SCHEDULER_EVICTION_STRATEGY	"resource.aware.scheduler.eviction.strategy"
public static final String	RESOURCE_AWARE_SCHEDULER_PRIORITY_STRATEGY	"resource.aware.scheduler.priority.strategy"
public static final String	RESOURCE_AWARE_SCHEDULER_USER_POOLS	"resource.aware.scheduler.user.pools"
public static final String	SCHEDULER_DISPLAY_RESOURCE	"scheduler.display.resource"
public static final String	STORM_BLOBSTORE_ACL_VALIDATION_ENABLED	"storm.blobstore.acl.validation.enabled"
public static final String	STORM_BLOBSTORE_INPUTSTREAM_BUFFER_SIZE_BYTES	"storm.blobstore.inputstream.buffer.size.bytes"
public static final String	STORM_BLOBSTORE_REPLICATION_FACTOR	"storm.blobstore.replication.factor"
public static final String	STORM_CGROUP_HIERARCHY_DIR	"storm.cgroup.hierarchy.dir"
public static final String	STORM_CGROUP_HIERARCHY_NAME	"storm.cgroup.hierarchy.name"
public static final String	STORM_CGROUP_RESOURCES	"storm.cgroup.resources"
public static final String	STORM_CLUSTER_METRICS_CONSUMER_PUBLISH_INTERVAL_SECS	"storm.cluster.metrics.consumer.publish.interval.secs"
public static final String	STORM_CLUSTER_METRICS_CONSUMER_REGISTER	"storm.cluster.metrics.consumer.register"
public static final String	STORM_CLUSTER_MODE	"storm.cluster.mode"
public static final String	STORM_CLUSTER_STATE_STORE	"storm.cluster.state.store"
public static final String	STORM_DAEMON_METRICS_REPORTER_CSV_LOG_DIR	"storm.daemon.metrics.reporter.csv.log.dir"
public static final String	STORM_DAEMON_METRICS_REPORTER_PLUGIN_DOMAIN	"storm.daemon.metrics.reporter.plugin.domain"
public static final String	STORM_DAEMON_METRICS_REPORTER_PLUGIN_DURATION_UNIT	"storm.daemon.metrics.reporter.plugin.duration.unit"
public static final String	STORM_DAEMON_METRICS_REPORTER_PLUGIN_LOCALE	"storm.daemon.metrics.reporter.plugin.locale"
public static final String	STORM_DAEMON_METRICS_REPORTER_PLUGIN_RATE_UNIT	"storm.daemon.metrics.reporter.plugin.rate.unit"
public static final String	STORM_DAEMON_METRICS_REPORTER_PLUGINS	"storm.daemon.metrics.reporter.plugins"
public static final String	STORM_DO_AS_USER	"storm.doAsUser"
public static final String	STORM_EXHIBITOR_POLL	"storm.exhibitor.poll.millis"
public static final String	STORM_EXHIBITOR_PORT	"storm.exhibitor.port"
public static final String	STORM_EXHIBITOR_RETRY_INTERVAL	"storm.exhibitor.retry.interval"
public static final String	STORM_EXHIBITOR_RETRY_INTERVAL_CEILING	"storm.exhibitor.retry.intervalceiling.millis"
public static final String	STORM_EXHIBITOR_RETRY_TIMES	"storm.exhibitor.retry.times"
public static final String	STORM_EXHIBITOR_SERVERS	"storm.exhibitor.servers"
public static final String	STORM_EXHIBITOR_URIPATH	"storm.exhibitor.poll.uripath"
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_PARAMS	"storm.group.mapping.service.params"
public static final String	STORM_GROUP_MAPPING_SERVICE_PROVIDER_PLUGIN	"storm.group.mapping.service"
public static final String	STORM_HEALTH_CHECK_DIR	"storm.health.check.dir"
public static final String	STORM_HEALTH_CHECK_TIMEOUT_MS	"storm.health.check.timeout.ms"
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_LOG4J2_CONF_DIR	"storm.log4j2.conf.dir"
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_NETWORK_TOPOGRAPHY_PLUGIN	"storm.network.topography.plugin"
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_RESOURCE_ISOLATION_PLUGIN	"storm.resource.isolation.plugin"
public static final String	STORM_RESOURCE_ISOLATION_PLUGIN_ENABLE	"storm.resource.isolation.plugin.enable"
public static final String	STORM_SCHEDULER	"storm.scheduler"
public static final String	STORM_THRIFT_TRANSPORT_PLUGIN	"storm.thrift.transport"
public static final String	STORM_TOPOLOGY_CLASSPATH_BEGINNING_ENABLED	"storm.topology.classpath.beginning.enabled"
public static final String	STORM_TOPOLOGY_SUBMISSION_NOTIFIER_PLUGIN	"storm.topology.submission.notifier.plugin.class"
public static final String	STORM_WORKERS_ARTIFACTS_DIR	"storm.workers.artifacts.dir"
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_BLOBSTORE	"supervisor.blobstore.class"
public static final String	SUPERVISOR_BLOBSTORE_DOWNLOAD_MAX_RETRIES	"supervisor.blobstore.download.max_retries"
public static final String	SUPERVISOR_BLOBSTORE_DOWNLOAD_THREAD_COUNT	"supervisor.blobstore.download.thread.count"
public static final String	SUPERVISOR_CHILDOPTS	"supervisor.childopts"
public static final String	SUPERVISOR_CPU_CAPACITY	"supervisor.cpu.capacity"
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_LOCALIZER_CACHE_CLEANUP_INTERVAL_MS	"supervisor.localizer.cleanup.interval.ms"
public static final String	SUPERVISOR_LOCALIZER_CACHE_TARGET_SIZE_MB	"supervisor.localizer.cache.target.size.mb"
public static final String	SUPERVISOR_MEMORY_CAPACITY_MB	"supervisor.memory.capacity.mb"
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_BACKPRESSURE_POLL_SECS	"task.backpressure.poll.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_BACKPRESSURE_ENABLE	"topology.backpressure.enable"
public static final String	TOPOLOGY_BLOBSTORE_MAP	"topology.blobstore.map"
public static final String	TOPOLOGY_BOLTS_LATE_TUPLE_STREAM	"topology.bolts.late.tuple.stream"
public static final String	TOPOLOGY_BOLTS_MESSAGE_ID_FIELD_NAME	"topology.bolts.message.id.field.name"
public static final String	TOPOLOGY_BOLTS_OUTGOING_OVERFLOW_BUFFER_ENABLE	"topology.bolts.outgoing.overflow.buffer.enable"
public static final String	TOPOLOGY_BOLTS_SLIDING_INTERVAL_COUNT	"topology.bolts.window.sliding.interval.count"
public static final String	TOPOLOGY_BOLTS_SLIDING_INTERVAL_DURATION_MS	"topology.bolts.window.sliding.interval.duration.ms"
public static final String	TOPOLOGY_BOLTS_TUPLE_TIMESTAMP_FIELD_NAME	"topology.bolts.tuple.timestamp.field.name"
public static final String	TOPOLOGY_BOLTS_TUPLE_TIMESTAMP_MAX_LAG_MS	"topology.bolts.tuple.timestamp.max.lag.ms"
public static final String	TOPOLOGY_BOLTS_WATERMARK_EVENT_INTERVAL_MS	"topology.bolts.watermark.event.interval.ms"
public static final String	TOPOLOGY_BOLTS_WINDOW_LENGTH_COUNT	"topology.bolts.window.length.count"
public static final String	TOPOLOGY_BOLTS_WINDOW_LENGTH_DURATION_MS	"topology.bolts.window.length.duration.ms"
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_CLASSPATH_BEGINNING	"topology.classpath.beginning"
public static final String	TOPOLOGY_COMPONENT_CPU_PCORE_PERCENT	"topology.component.cpu.pcore.percent"
public static final String	TOPOLOGY_COMPONENT_RESOURCES_OFFHEAP_MEMORY_MB	"topology.component.resources.offheap.memory.mb"
public static final String	TOPOLOGY_COMPONENT_RESOURCES_ONHEAP_MEMORY_MB	"topology.component.resources.onheap.memory.mb"
public static final String	TOPOLOGY_DEBUG	"topology.debug"
public static final String	TOPOLOGY_DISABLE_LOADAWARE_MESSAGING	"topology.disable.loadaware.messaging"
public static final String	TOPOLOGY_DISRUPTOR_BATCH_SIZE	"topology.disruptor.batch.size"
public static final String	TOPOLOGY_DISRUPTOR_BATCH_TIMEOUT_MILLIS	"topology.disruptor.batch.timeout.millis"
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_EVENTLOGGER_EXECUTORS	"topology.eventlogger.executors"
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_REPLICATION_WAIT_TIME_SEC	"topology.max.replication.wait.time.sec"
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_MIN_REPLICATION_COUNT	"topology.min.replication.count"
public static final String	TOPOLOGY_MULTILANG_SERIALIZER	"topology.multilang.serializer"
public static final String	TOPOLOGY_NAME	"topology.name"
public static final String	TOPOLOGY_PRIORITY	"topology.priority"
public static final String	TOPOLOGY_SCHEDULER_STRATEGY	"topology.scheduler.strategy"
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_CHECKPOINT_INTERVAL	"topology.state.checkpoint.interval.ms"
public static final String	TOPOLOGY_STATE_PROVIDER	"topology.state.provider"
public static final String	TOPOLOGY_STATE_PROVIDER_CONFIG	"topology.state.provider.config"
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_SUBPROCESS_TIMEOUT_SECS	"topology.subprocess.timeout.secs"
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_TRIDENT_WINDOWING_INMEMORY_CACHE_LIMIT	"topology.trident.windowing.cache.tuple.limit"
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_LOGWRITER_CHILDOPTS	"topology.worker.logwriter.childopts"
public static final String	TOPOLOGY_WORKER_MAX_HEAP_SIZE_MB	"topology.worker.max.heap.size.mb"
public static final String	TOPOLOGY_WORKER_METRICS	"topology.worker.metrics"
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_CENTRAL_LOGGING_URL	"ui.central.logging.url"
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	UI_PROJECT_BUGTRACKER_URL	"ui.project.bugtracker.url"
public static final String	WORKER_CHILDOPTS	"worker.childopts"
public static final String	WORKER_GC_CHILDOPTS	"worker.gc.childopts"
public static final String	WORKER_HEAP_MEMORY_MB	"worker.heap.memory.mb"
public static final String	WORKER_HEARTBEAT_FREQUENCY_SECS	"worker.heartbeat.frequency.secs"
public static final String	WORKER_LOG_LEVEL_RESET_POLL_SECS	"worker.log.level.reset.poll.secs"
public static final String	WORKER_METRICS	"worker.metrics"
public static final String	WORKER_PROFILER_CHILDOPTS	"worker.profiler.childopts"
public static final String	WORKER_PROFILER_COMMAND	"worker.profiler.command"
public static final String	WORKER_PROFILER_ENABLED	"worker.profiler.enabled"
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"

org.apache.storm.Constants

Modifier and Type	Constant Field	Value
public static final String	COMPONENT_TO_DEBUG_ATOM	"storm-component->debug-atom"
public static final String	COMPONENT_TO_SORTED_TASKS	"component->sorted-tasks"
public static final String	COMPONENT_TO_STREAM_TO_FIELDS	"component->stream->fields"
public static final String	CONF	"conf"
public static final String	CREDENTIALS_CHANGED_STREAM_ID	"__credentials"
public static final String	DEFAULT_SHARED_RESOURCES	"default-shared-resources"
public static final String	EXECUTOR_RECEIVE_QUEUE_MAP	"executor-receive-queue-map"
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	PORT	"port"
public static final String	STORM_ACTIVE_ATOM	"storm-active-atom"
public static final String	STORM_CONF	"storm-conf"
public static final String	STORM_ID	"storm-id"
public static final String	SUICIDE_FN	"suicide-fn"
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"
public static final String	SYSTEM_TOPOLOGY	"system-topology"
public static final String	TASK_IDS	"task-ids"
public static final String	TASK_TO_COMPONENT	"task->component"
public static final String	THROTTLE_ON	"throttle-on"
public static final String	TRANSFER_FN	"transfer-fn"
public static final String	USER_SHARED_RESOURCES	"user-shared-resources"
public static final String	USER_TIMER	"user-timer"
public static final String	WORKER_ID	"worker-id"

org.apache.storm.blobstore.BlobStore

Modifier and Type	Constant Field	Value
protected static final String	BASE_BLOBS_DIR_NAME	"blobs"

org.apache.storm.blobstore.BlobStoreAclHandler

Modifier and Type	Constant Field	Value
public static final int	ADMIN	4
public static final int	READ	1
public static final int	WRITE	2

org.apache.storm.blobstore.BlobStoreFile

Modifier and Type	Constant Field	Value
protected static final String	BLOBSTORE_DATA_FILE	"data"
protected static final String	TMP_EXT	".tmp"

org.apache.storm.cassandra.bolt.BatchCassandraWriterBolt

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_EMIT_FREQUENCY	2

org.apache.storm.cassandra.client.CassandraConf

Modifier and Type	Constant Field	Value
public static final String	CASSANDRA_BATCH_SIZE_ROWS	"cassandra.batch.size.rows"
public static final String	CASSANDRA_CONSISTENCY_LEVEL	"cassandra.output.consistencyLevel"
public static final String	CASSANDRA_KEYSPACE	"cassandra.keyspace"
public static final String	CASSANDRA_NODES	"cassandra.nodes"
public static final String	CASSANDRA_PASSWORD	"cassandra.password"
public static final String	CASSANDRA_PORT	"cassandra.port"
public static final String	CASSANDRA_RECONNECT_POLICY_BASE_MS	"cassandra.reconnectionPolicy.baseDelayMs"
public static final String	CASSANDRA_RECONNECT_POLICY_MAX_MS	"cassandra.reconnectionPolicy.maxDelayMs"
public static final String	CASSANDRA_RETRY_POLICY	"cassandra.retryPolicy"
public static final String	CASSANDRA_USERNAME	"cassandra.username"

org.apache.storm.cluster.ClusterUtils

Modifier and Type	Constant Field	Value
public static final String	ASSIGNMENTS_ROOT	"assignments"
public static final String	ASSIGNMENTS_SUBTREE	"/assignments"
public static final String	BACKPRESSURE_ROOT	"backpressure"
public static final String	BACKPRESSURE_SUBTREE	"/backpressure"
public static final String	BLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_ROOT	"blobstoremaxkeysequencenumber"
public static final String	BLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_SUBTREE	"/blobstoremaxkeysequencenumber"
public static final String	BLOBSTORE_ROOT	"blobstore"
public static final String	BLOBSTORE_SUBTREE	"/blobstore"
public static final String	CODE_ROOT	"code"
public static final String	CREDENTIALS_ROOT	"credentials"
public static final String	CREDENTIALS_SUBTREE	"/credentials"
public static final String	ERRORS_ROOT	"errors"
public static final String	ERRORS_SUBTREE	"/errors"
public static final String	LOGCONFIG_ROOT	"logconfigs"
public static final String	LOGCONFIG_SUBTREE	"/logconfigs"
public static final String	NIMBUSES_ROOT	"nimbuses"
public static final String	NIMBUSES_SUBTREE	"/nimbuses"
public static final String	PROFILERCONFIG_ROOT	"profilerconfigs"
public static final String	PROFILERCONFIG_SUBTREE	"/profilerconfigs"
public static final String	STORMS_ROOT	"storms"
public static final String	STORMS_SUBTREE	"/storms"
public static final String	SUPERVISORS_ROOT	"supervisors"
public static final String	SUPERVISORS_SUBTREE	"/supervisors"
public static final String	WORKERBEATS_ROOT	"workerbeats"
public static final String	WORKERBEATS_SUBTREE	"/workerbeats"
public static final String	ZK_SEPERATOR	"/"

org.apache.storm.container.cgroup.CgroupCommon

Modifier and Type	Constant Field	Value
public static final String	CGROUP_CLONE_CHILDREN	"/cgroup.clone_children"
public static final String	CGROUP_EVENT_CONTROL	"/cgroup.event_control"
public static final String	CGROUP_PROCS	"/cgroup.procs"
public static final String	NOTIFY_ON_RELEASE	"/notify_on_release"
public static final String	RELEASE_AGENT	"/release_agent"
public static final String	TASKS	"/tasks"

org.apache.storm.container.cgroup.CgroupUtils

Modifier and Type	Constant Field	Value
public static final String	CGROUP_STATUS_FILE	"/proc/cgroups"
public static final String	MOUNT_STATUS_FILE	"/proc/mounts"

org.apache.storm.container.cgroup.core.BlkioCore

Modifier and Type	Constant Field	Value
public static final String	BLKIO_IO_MERGED	"/blkio.io_merged"
public static final String	BLKIO_IO_QUEUED	"/blkio.io_queued"
public static final String	BLKIO_IO_SERVICE_BYTES	"/blkio.io_service_bytes"
public static final String	BLKIO_IO_SERVICE_TIME	"/blkio.io_service_time"
public static final String	BLKIO_IO_SERVICED	"/blkio.io_serviced"
public static final String	BLKIO_IO_WAIT_TIME	"/blkio.io_wait_time"
public static final String	BLKIO_RESET_STATS	"/blkio.reset_stats"
public static final String	BLKIO_SECTORS	"/blkio.sectors"
public static final String	BLKIO_THROTTLE_IO_SERVICE_BYTES	"/blkio.throttle.io_service_bytes"
public static final String	BLKIO_THROTTLE_IO_SERVICED	"/blkio.throttle.io_serviced"
public static final String	BLKIO_THROTTLE_READ_BPS_DEVICE	"/blkio.throttle.read_bps_device"
public static final String	BLKIO_THROTTLE_READ_IOPS_DEVICE	"/blkio.throttle.read_iops_device"
public static final String	BLKIO_THROTTLE_WRITE_BPS_DEVICE	"/blkio.throttle.write_bps_device"
public static final String	BLKIO_THROTTLE_WRITE_IOPS_DEVICE	"/blkio.throttle.write_iops_device"
public static final String	BLKIO_TIME	"/blkio.time"
public static final String	BLKIO_WEIGHT	"/blkio.weight"
public static final String	BLKIO_WEIGHT_DEVICE	"/blkio.weight_device"

org.apache.storm.container.cgroup.core.CpuacctCore

Modifier and Type	Constant Field	Value
public static final String	CPUACCT_STAT	"/cpuacct.stat"
public static final String	CPUACCT_USAGE	"/cpuacct.usage"
public static final String	CPUACCT_USAGE_PERCPU	"/cpuacct.usage_percpu"

org.apache.storm.container.cgroup.core.CpuCore

Modifier and Type	Constant Field	Value
public static final String	CPU_CFS_PERIOD_US	"/cpu.cfs_period_us"
public static final String	CPU_CFS_QUOTA_US	"/cpu.cfs_quota_us"
public static final String	CPU_RT_PERIOD_US	"/cpu.rt_period_us"
public static final String	CPU_RT_RUNTIME_US	"/cpu.rt_runtime_us"
public static final String	CPU_SHARES	"/cpu.shares"
public static final String	CPU_STAT	"/cpu.stat"

org.apache.storm.container.cgroup.core.CpusetCore

Modifier and Type	Constant Field	Value
public static final String	CPUSET_CPU_EXCLUSIVE	"/cpuset.cpu_exclusive"
public static final String	CPUSET_CPUS	"/cpuset.cpus"
public static final String	CPUSET_MEM_EXCLUSIVE	"/cpuset.mem_exclusive"
public static final String	CPUSET_MEM_HARDWALL	"/cpuset.mem_hardwall"
public static final String	CPUSET_MEMORY_MIGRATE	"/cpuset.memory_migrate"
public static final String	CPUSET_MEMORY_PRESSURE	"/cpuset.memory_pressure"
public static final String	CPUSET_MEMORY_PRESSURE_ENABLED	"/cpuset.memory_pressure_enabled"
public static final String	CPUSET_MEMORY_SPREAD_PAGE	"/cpuset.memory_spread_page"
public static final String	CPUSET_MEMORY_SPREAD_SLAB	"/cpuset.memory_spread_slab"
public static final String	CPUSET_MEMS	"/cpuset.mems"
public static final String	CPUSET_SCHED_LOAD_BALANCE	"/cpuset.sched_load_balance"
public static final String	CPUSET_SCHED_RELAX_DOMAIN_LEVEL	"/cpuset.sched_relax_domain_level"

org.apache.storm.container.cgroup.core.FreezerCore

Modifier and Type	Constant Field	Value
public static final String	FREEZER_STATE	"/freezer.state"

org.apache.storm.container.cgroup.core.MemoryCore

Modifier and Type	Constant Field	Value
public static final String	MEMORY_FAILCNT	"/memory.failcnt"
public static final String	MEMORY_FORCE_EMPTY	"/memory.force_empty"
public static final String	MEMORY_LIMIT_IN_BYTES	"/memory.limit_in_bytes"
public static final String	MEMORY_MAX_USAGE_IN_BYTES	"/memory.max_usage_in_bytes"
public static final String	MEMORY_MEMSW_FAILCNT	"/memory.memsw.failcnt"
public static final String	MEMORY_MEMSW_LIMIT_IN_BYTES	"/memory.memsw.limit_in_bytes"
public static final String	MEMORY_MEMSW_MAX_USAGE_IN_BYTES	"/memory.memsw.max_usage_in_bytes"
public static final String	MEMORY_MEMSW_USAGE_IN_BYTES	"/memory.memsw.usage_in_bytes"
public static final String	MEMORY_OOM_CONTROL	"/memory.oom_control"
public static final String	MEMORY_STAT	"/memory.stat"
public static final String	MEMORY_SWAPPINESS	"/memory.swappiness"
public static final String	MEMORY_USAGE_IN_BYTES	"/memory.usage_in_bytes"
public static final String	MEMORY_USE_HIERARCHY	"/memory.use_hierarchy"

org.apache.storm.container.cgroup.core.NetClsCore

Modifier and Type	Constant Field	Value
public static final String	NET_CLS_CLASSID	"/net_cls.classid"

org.apache.storm.container.cgroup.core.NetPrioCore

Modifier and Type	Constant Field	Value
public static final String	NET_PRIO_IFPRIOMAP	"/net_prio.ifpriomap"
public static final String	NET_PRIO_PRIOIDX	"/net_prio.prioidx"

org.apache.storm.daemon.Acker

Modifier and Type	Constant Field	Value
public static final String	ACKER_ACK_STREAM_ID	"__ack_ack"
public static final String	ACKER_COMPONENT_ID	"__acker"
public static final String	ACKER_FAIL_STREAM_ID	"__ack_fail"
public static final String	ACKER_INIT_STREAM_ID	"__ack_init"
public static final String	ACKER_RESET_TIMEOUT_STREAM_ID	"__ack_reset_timeout"
public static final int	TIMEOUT_BUCKET_NUM	3

org.apache.storm.daemon.StormCommon

Modifier and Type	Constant Field	Value
public static final String	EVENTLOGGER_COMPONENT_ID	"__eventlogger"
public static final String	EVENTLOGGER_STREAM_ID	"__eventlog"
public static final String	SYSTEM_STREAM_ID	"__system"
public static final String	TOPOLOGY_METRICS_CONSUMER_ARGUMENT	"argument"
public static final String	TOPOLOGY_METRICS_CONSUMER_BLACKLIST	"blacklist"
public static final String	TOPOLOGY_METRICS_CONSUMER_CLASS	"class"
public static final String	TOPOLOGY_METRICS_CONSUMER_EXPAND_MAP_TYPE	"expandMapType"
public static final String	TOPOLOGY_METRICS_CONSUMER_MAX_RETAIN_METRIC_TUPLES	"max.retain.metric.tuples"
public static final String	TOPOLOGY_METRICS_CONSUMER_METRIC_NAME_SEPARATOR	"metricNameSeparator"
public static final String	TOPOLOGY_METRICS_CONSUMER_PARALLELISM_HINT	"parallelism.hint"
public static final String	TOPOLOGY_METRICS_CONSUMER_WHITELIST	"whitelist"

org.apache.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"

org.apache.storm.druid.bolt.DruidConfig

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_DISCARD_STREAM_ID	"druid-discard-stream"

org.apache.storm.druid.bolt.TupleDruidEventMapper<E>

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_FIELD_NAME	"event"

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	META_DATA	"metadata"
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.hbase.trident.windowing.HBaseWindowsStore

Modifier and Type	Constant Field	Value
public static final String	UTF_8	"utf-8"

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.spout.Configs

Modifier and Type	Constant Field	Value
public static final String	ARCHIVE_DIR	"hdfsspout.archive.dir"
public static final String	BAD_DIR	"hdfsspout.badfiles.dir"
public static final String	CLOCKS_INSYNC	"hdfsspout.clocks.insync"
public static final String	COMMIT_FREQ_COUNT	"hdfsspout.commit.count"
public static final String	COMMIT_FREQ_SEC	"hdfsspout.commit.sec"
public static final int	DEFAULT_COMMIT_FREQ_COUNT	20000
public static final int	DEFAULT_COMMIT_FREQ_SEC	10
public static final String	DEFAULT_HDFS_CONFIG_KEY	"hdfs.config"
public static final String	DEFAULT_LOCK_DIR	".lock"
public static final int	DEFAULT_LOCK_TIMEOUT	300
public static final int	DEFAULT_MAX_OUTSTANDING	10000
public static final String	HDFS_URI	"hdfsspout.hdfs"
public static final String	IGNORE_SUFFIX	"hdfsspout.ignore.suffix"
public static final String	LOCK_DIR	"hdfsspout.lock.dir"
public static final String	LOCK_TIMEOUT	"hdfsspout.lock.timeout.sec"
public static final String	MAX_OUTSTANDING	"hdfsspout.max.outstanding"
public static final String	READER_TYPE	"hdfsspout.reader.type"
public static final String	SEQ	"seq"
public static final String	SOURCE_DIR	"hdfsspout.source.dir"
public static final String	TEXT	"text"

org.apache.storm.hdfs.spout.DirLock

Modifier and Type	Constant Field	Value
public static final String	DIR_LOCK_FILE	"DIRLOCK"

org.apache.storm.hdfs.spout.SequenceFileReader<Key extends org.apache.hadoop.io.Writable,Value extends org.apache.hadoop.io.Writable>

Modifier and Type	Constant Field	Value
public static final String	BUFFER_SIZE	"hdfsspout.reader.buffer.bytes"

org.apache.storm.hdfs.spout.TextFileReader

Modifier and Type	Constant Field	Value
public static final String	BUFFER_SIZE	"hdfsspout.reader.buffer.bytes"
public static final String	CHARSET	"hdfsspout.reader.charset"

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.jdbc.topology.AbstractUserTopology

Modifier and Type	Constant Field	Value
protected static final String	JDBC_CONF	"jdbc.conf"
protected static final String	SELECT_QUERY	"select dept_name from department, user_department where department.dept_id = user_department.dept_id and user_department.user_id = ?"
protected static final String	TABLE_NAME	"user"

org.apache.storm.jms.example.ExampleJmsTopology

Modifier and Type	Constant Field	Value
public static final String	ANOTHER_BOLT	"ANOTHER_BOLT"
public static final String	FINAL_BOLT	"FINAL_BOLT"
public static final String	INTERMEDIATE_BOLT	"INTERMEDIATE_BOLT"
public static final String	JMS_QUEUE_SPOUT	"JMS_QUEUE_SPOUT"
public static final String	JMS_TOPIC_BOLT	"JMS_TOPIC_BOLT"
public static final String	JMS_TOPIC_SPOUT	"JMS_TOPIC_SPOUT"

org.apache.storm.jms.trident.TridentJmsSpout

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

org.apache.storm.kafka.StringMessageAndMetadataScheme

Modifier and Type	Constant Field	Value
public static final String	STRING_SCHEME_OFFSET	"offset"
public static final String	STRING_SCHEME_PARTITION_KEY	"partition"

org.apache.storm.kafka.StringMultiSchemeWithTopic

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

org.apache.storm.kafka.StringScheme

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

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

Modifier and Type	Constant Field	Value
public static final String	TOPIC	"topic"

org.apache.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"

org.apache.storm.kafka.spout.KafkaSpoutConfig<K,V>

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_RETRIES	2147483647
public static final int	DEFAULT_MAX_UNCOMMITTED_OFFSETS	10000000
public static final long	DEFAULT_OFFSET_COMMIT_PERIOD_MS	30000L
public static final long	DEFAULT_POLL_TIMEOUT_MS	200L

org.apache.storm.kafka.spout.KafkaSpoutConfig.Consumer

Modifier and Type	Constant Field	Value
public static final String	AUTO_COMMIT_INTERVAL_MS	"auto.commit.interval.ms"
public static final String	BOOTSTRAP_SERVERS	"bootstrap.servers"
public static final String	ENABLE_AUTO_COMMIT	"enable.auto.commit"
public static final String	GROUP_ID	"group.id"
public static final String	KEY_DESERIALIZER	"key.deserializer"
public static final String	VALUE_DESERIALIZER	"value.deserializer"

org.apache.storm.localizer.Localizer

Modifier and Type	Constant Field	Value
public static final String	ARCHIVESDIR	"archives"
public static final String	FILECACHE	"filecache"
public static final String	FILESDIR	"files"
public static final String	USERCACHE	"usercache"

org.apache.storm.messaging.netty.SaslMessageToken

Modifier and Type	Constant Field	Value
public static final short	IDENTIFIER	-500

org.apache.storm.metric.EventLoggerBolt

Modifier and Type	Constant Field	Value
public static final String	FIELD_COMPONENT_ID	"component-id"
public static final String	FIELD_MESSAGE_ID	"message-id"
public static final String	FIELD_TS	"ts"
public static final String	FIELD_VALUES	"values"

org.apache.storm.multilang.JsonSerializer

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_CHARSET	"UTF-8"

org.apache.storm.networktopography.DNSToSwitchMapping

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_RACK	"/default-rack"

org.apache.storm.pacemaker.codec.ThriftNettyClientCodec

Modifier and Type	Constant Field	Value
public static final String	KERBEROS_HANDLER	"kerberos-handler"
public static final String	SASL_HANDLER	"sasl-handler"

org.apache.storm.pacemaker.codec.ThriftNettyServerCodec

Modifier and Type	Constant Field	Value
public static final String	KERBEROS_HANDLER	"kerberos-handler"
public static final String	SASL_HANDLER	"sasl-handler"

org.apache.storm.security.auth.AbstractSaslClientCallbackHandler

Modifier and Type	Constant Field	Value
protected static final String	PASSWORD	"password"
protected static final String	USERNAME	"username"

org.apache.storm.security.auth.AuthUtils

Modifier and Type	Constant Field	Value
public static final String	LOGIN_CONTEXT_CLIENT	"StormClient"
public static final String	LOGIN_CONTEXT_PACEMAKER_CLIENT	"PacemakerClient"
public static final String	LOGIN_CONTEXT_PACEMAKER_DIGEST	"PacemakerDigest"
public static final String	LOGIN_CONTEXT_PACEMAKER_SERVER	"PacemakerServer"
public static final String	LOGIN_CONTEXT_SERVER	"StormServer"
public static final String	SERVICE	"storm_thrift_server"

org.apache.storm.security.auth.AutoSSL

Modifier and Type	Constant Field	Value
public static final String	SSL_FILES_CONF	"ssl.credential.files"

org.apache.storm.security.auth.authorizer.DRPCAuthorizerBase

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

org.apache.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"

org.apache.storm.security.auth.authorizer.ImpersonationAuthorizer

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

org.apache.storm.security.auth.authorizer.SimpleWhitelistAuthorizer

Modifier and Type	Constant Field	Value
public static final String	WHITELIST_USERS_CONF	"storm.auth.simple-white-list.users"

org.apache.storm.security.auth.digest.DigestSaslTransportPlugin

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

org.apache.storm.security.auth.digest.ServerCallbackHandler

Modifier and Type	Constant Field	Value
public static final String	SYSPROP_SUPER_PASSWORD	"storm.SASLAuthenticationProvider.superPassword"

org.apache.storm.security.auth.kerberos.KerberosSaslTransportPlugin

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

org.apache.storm.security.auth.kerberos.NoOpTTrasport

Modifier and Type	Constant Field	Value
protected static final int	DEFAULT_MAX_LENGTH	2147483647
protected static final int	MECHANISM_NAME_BYTES	1
protected static final int	PAYLOAD_LENGTH_BYTES	4
protected static final int	STATUS_BYTES	1

org.apache.storm.security.auth.plain.PlainSaslTransportPlugin

Modifier and Type	Constant Field	Value
public static final String	PLAIN	"PLAIN"

org.apache.storm.security.auth.plain.PlainServerCallbackHandler

Modifier and Type	Constant Field	Value
public static final String	PASSWORD	"password"

org.apache.storm.security.auth.plain.SaslPlainServer.SecurityProvider

Modifier and Type	Constant Field	Value
public static final String	SASL_PLAIN_SERVER	"SaslPlainServer"

org.apache.storm.security.serialization.BlowfishTupleSerializer

Modifier and Type	Constant Field	Value
public static final String	SECRET_KEY	"topology.tuple.serializer.blowfish.key"

org.apache.storm.spout.CheckpointSpout

Modifier and Type	Constant Field	Value
public static final String	CHECKPOINT_COMPONENT_ID	"$checkpointspout"
public static final String	CHECKPOINT_FIELD_ACTION	"action"
public static final String	CHECKPOINT_FIELD_TXID	"txid"
public static final String	CHECKPOINT_STREAM_ID	"$checkpoint"

org.apache.storm.sql.parser.StormParser

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_IDENTIFIER_MAX_LENGTH	128

org.apache.storm.sql.parser.impl.SimpleCharStream

Modifier and Type	Constant Field	Value
public static final boolean	staticFlag	false

org.apache.storm.sql.parser.impl.StormParserImplConstants

Modifier and Type	Constant Field	Value
public static final int	A	1
public static final int	ABS	2
public static final int	ABSOLUTE	3
public static final int	ACTION	4
public static final int	ADA	5
public static final int	ADD	6
public static final int	ADMIN	7
public static final int	AFTER	8
public static final int	ALL	9
public static final int	ALLOCATE	10
public static final int	ALLOW	11
public static final int	ALTER	13
public static final int	ALWAYS	12
public static final int	AND	14
public static final int	ANY	15
public static final int	APPROX_NUMERIC_LITERAL	556
public static final int	ARE	16
public static final int	ARRAY	17
public static final int	AS	18
public static final int	ASC	19
public static final int	ASENSITIVE	20
public static final int	ASSERTION	21
public static final int	ASSIGNMENT	22
public static final int	ASYMMETRIC	23
public static final int	AT	24
public static final int	ATOMIC	25
public static final int	ATTRIBUTE	26
public static final int	ATTRIBUTES	27
public static final int	AUTHORIZATION	28
public static final int	AVG	29
public static final int	BACK_QUOTED_IDENTIFIER	611
public static final int	BEFORE	30
public static final int	BEGIN	31
public static final int	BEL	617
public static final int	BERNOULLI	32
public static final int	BETWEEN	33
public static final int	BIGINT	34
public static final int	BINARY	35
public static final int	BINARY_STRING_LITERAL	561
public static final int	BIT	36
public static final int	BLOB	37
public static final int	BOOLEAN	38
public static final int	BOTH	39
public static final int	BRACKET_QUOTED_IDENTIFIER	609
public static final int	BREADTH	40
public static final int	BTID	2
public static final int	BY	41
public static final int	C	42
public static final int	CALL	43
public static final int	CALLED	44
public static final int	CARDINALITY	45
public static final int	CASCADE	46
public static final int	CASCADED	47
public static final int	CASE	48
public static final int	CAST	49
public static final int	CATALOG	50
public static final int	CATALOG_NAME	51
public static final int	CEIL	52
public static final int	CEILING	53
public static final int	CENTURY	54
public static final int	CHAIN	55
public static final int	CHAR	56
public static final int	CHAR_LENGTH	57
public static final int	CHARACTER	58
public static final int	CHARACTER_LENGTH	59
public static final int	CHARACTER_SET_CATALOG	60
public static final int	CHARACTER_SET_NAME	61
public static final int	CHARACTER_SET_SCHEMA	62
public static final int	CHARACTERISTICS	63
public static final int	CHARACTERS	64
public static final int	CHARSETNAME	565
public static final int	CHECK	65
public static final int	CLASS_ORIGIN	66
public static final int	CLOB	67
public static final int	CLOSE	68
public static final int	COALESCE	69
public static final int	COBOL	70
public static final int	COLLATE	71
public static final int	COLLATION	72
public static final int	COLLATION_CATALOG	73
public static final int	COLLATION_ID	612
public static final int	COLLATION_NAME	74
public static final int	COLLATION_SCHEMA	75
public static final int	COLLECT	76
public static final int	COLON	584
public static final int	COLUMN	77
public static final int	COLUMN_NAME	78
public static final int	COMMA	579
public static final int	COMMAND_FUNCTION	79
public static final int	COMMAND_FUNCTION_CODE	80
public static final int	COMMIT	81
public static final int	COMMITTED	82
public static final int	CONCAT	593
public static final int	CONDITION	83
public static final int	CONDITION_NUMBER	84
public static final int	CONNECT	85
public static final int	CONNECTION	86
public static final int	CONNECTION_NAME	87
public static final int	CONSTRAINT	88
public static final int	CONSTRAINT_CATALOG	89
public static final int	CONSTRAINT_NAME	90
public static final int	CONSTRAINT_SCHEMA	91
public static final int	CONSTRAINTS	92
public static final int	CONSTRUCTOR	93
public static final int	CONTAINS	94
public static final int	CONTINUE	96
public static final int	CONVERT	95
public static final int	CORR	97
public static final int	CORRESPONDING	98
public static final int	COUNT	99
public static final int	COVAR_POP	100
public static final int	COVAR_SAMP	101
public static final int	CREATE	102
public static final int	CROSS	103
public static final int	CUBE	104
public static final int	CUME_DIST	105
public static final int	CURRENT	106
public static final int	CURRENT_CATALOG	107
public static final int	CURRENT_DATE	108
public static final int	CURRENT_DEFAULT_TRANSFORM_GROUP	109
public static final int	CURRENT_PATH	110
public static final int	CURRENT_ROLE	111
public static final int	CURRENT_SCHEMA	112
public static final int	CURRENT_TIME	113
public static final int	CURRENT_TIMESTAMP	114
public static final int	CURRENT_TRANSFORM_GROUP_FOR_TYPE	115
public static final int	CURRENT_USER	116
public static final int	CURSOR	117
public static final int	CURSOR_NAME	118
public static final int	CYCLE	119
public static final int	DATA	120
public static final int	DATABASE	121
public static final int	DATE	122
public static final int	DATETIME_INTERVAL_CODE	123
public static final int	DATETIME_INTERVAL_PRECISION	124
public static final int	DAY	125
public static final int	DEALLOCATE	126
public static final int	DEC	127
public static final int	DECADE	128
public static final int	DECIMAL	129
public static final int	DECIMAL_NUMERIC_LITERAL	557
public static final int	DECLARE	130
public static final int	DEFAULT	0
public static final int	DEFAULT_KW	131
public static final int	DEFAULTS	132
public static final int	DEFERRABLE	133
public static final int	DEFERRED	134
public static final int	DEFINED	135
public static final int	DEFINER	136
public static final int	DEGREE	137
public static final int	DELETE	138
public static final int	DENSE_RANK	139
public static final int	DEPTH	140
public static final int	DEREF	141
public static final int	DERIVED	142
public static final int	DESC	144
public static final int	DESCRIBE	143
public static final int	DESCRIPTION	145
public static final int	DESCRIPTOR	146
public static final int	DETERMINISTIC	147
public static final int	DIAGNOSTICS	148
public static final int	DIGIT	616
public static final int	DISALLOW	149
public static final int	DISCONNECT	150
public static final int	DISPATCH	151
public static final int	DISTINCT	152
public static final int	DOMAIN	153
public static final int	DOT	578
public static final int	DOUBLE	154
public static final int	DOUBLE_PERIOD	595
public static final int	DOUBLE_QUOTE	597
public static final int	DOW	155
public static final int	DOY	156
public static final int	DQID	1
public static final int	DROP	157
public static final int	DYNAMIC	158
public static final int	DYNAMIC_FUNCTION	159
public static final int	DYNAMIC_FUNCTION_CODE	160
public static final int	EACH	161
public static final int	ELEMENT	162
public static final int	ELSE	163
public static final int	END	164
public static final int	END_EXEC	165
public static final int	EOF	0
public static final int	EPOCH	166
public static final int	EQ	580
public static final int	EQUALS	167
public static final int	ESCAPE	168
public static final int	EVERY	169
public static final int	EXCEPT	170
public static final int	EXCEPTION	171
public static final int	EXCLUDE	172
public static final int	EXCLUDING	173
public static final int	EXEC	174
public static final int	EXECUTE	175
public static final int	EXISTS	176
public static final int	EXP	177
public static final int	EXPLAIN	178
public static final int	EXPONENT	558
public static final int	EXTEND	180
public static final int	EXTERNAL	179
public static final int	EXTRACT	181
public static final int	FALSE	182
public static final int	FETCH	183
public static final int	FILTER	184
public static final int	FINAL	185
public static final int	FIRST	186
public static final int	FIRST_VALUE	187
public static final int	FLOAT	188
public static final int	FLOOR	189
public static final int	FOLLOWING	190
public static final int	FOR	191
public static final int	FOREIGN	192
public static final int	FORMAL_COMMENT	606
public static final int	FORTRAN	193
public static final int	FOUND	194
public static final int	FRAC_SECOND	195
public static final int	FREE	196
public static final int	FROM	197
public static final int	FULL	198
public static final int	FUNCTION	199
public static final int	FUSION	200
public static final int	G	201
public static final int	GE	586
public static final int	GENERAL	202
public static final int	GENERATED	203
public static final int	GET	204
public static final int	GLOBAL	205
public static final int	GO	206
public static final int	GOTO	207
public static final int	GRANT	208
public static final int	GRANTED	209
public static final int	GROUP	210
public static final int	GROUPING	211
public static final int	GT	581
public static final int	HAVING	212
public static final int	HEXDIGIT	559
public static final int	HIERARCHY	213
public static final int	HOLD	214
public static final int	HOOK	583
public static final int	HOUR	215
public static final int	IDENTIFIER	613
public static final int	IDENTITY	216
public static final int	IMMEDIATE	217
public static final int	IMPLEMENTATION	218
public static final int	IMPORT	219
public static final int	IN	220
public static final int	IN_FORMAL_COMMENT	3
public static final int	IN_MULTI_LINE_COMMENT	4
public static final int	INCLUDING	222
public static final int	INCREMENT	223
public static final int	INDICATOR	221
public static final int	INITIALLY	224
public static final int	INNER	225
public static final int	INOUT	226
public static final int	INPUT	227
public static final int	INPUTFORMAT	550
public static final int	INSENSITIVE	228
public static final int	INSERT	229
public static final int	INSTANCE	230
public static final int	INSTANTIABLE	231
public static final int	INT	232
public static final int	INTEGER	233
public static final int	INTERSECT	234
public static final int	INTERSECTION	235
public static final int	INTERVAL	236
public static final int	INTO	237
public static final int	INVOKER	238
public static final int	IS	239
public static final int	ISOLATION	240
public static final int	JAR	554
public static final int	JAVA	241
public static final int	JOIN	242
public static final int	K	243
public static final int	KEY	244
public static final int	KEY_MEMBER	245
public static final int	KEY_TYPE	246
public static final int	LABEL	247
public static final int	LANGUAGE	248
public static final int	LARGE	249
public static final int	LAST	250
public static final int	LAST_VALUE	251
public static final int	LATERAL	252
public static final int	LBRACE	573
public static final int	LBRACE_D	569
public static final int	LBRACE_FN	572
public static final int	LBRACE_T	570
public static final int	LBRACE_TS	571
public static final int	LBRACKET	575
public static final int	LE	585
public static final int	LEADING	253
public static final int	LEFT	254
public static final int	LENGTH	255
public static final int	LETTER	615
public static final int	LEVEL	256
public static final int	LIBRARY	257
public static final int	LIKE	258
public static final int	LIMIT	259
public static final int	LN	260
public static final int	LOCAL	261
public static final int	LOCALTIME	262
public static final int	LOCALTIMESTAMP	263
public static final int	LOCATION	549
public static final int	LOCATOR	264
public static final int	LOWER	265
public static final int	LPAREN	567
public static final int	LT	582
public static final int	M	266
public static final int	MAP	267
public static final int	MATCH	268
public static final int	MATCHED	269
public static final int	MAX	270
public static final int	MAXVALUE	271
public static final int	MEMBER	272
public static final int	MERGE	273
public static final int	MESSAGE_LENGTH	274
public static final int	MESSAGE_OCTET_LENGTH	275
public static final int	MESSAGE_TEXT	276
public static final int	METHOD	277
public static final int	MICROSECOND	278
public static final int	MILLENNIUM	279
public static final int	MIN	280
public static final int	MINUS	590
public static final int	MINUTE	281
public static final int	MINVALUE	282
public static final int	MOD	283
public static final int	MODIFIES	284
public static final int	MODULE	285
public static final int	MONTH	286
public static final int	MORE_KW	287
public static final int	MULTI_LINE_COMMENT	607
public static final int	MULTISET	288
public static final int	MUMPS	289
public static final int	NAME	290
public static final int	NAMED_ARGUMENT_ASSIGNMENT	594
public static final int	NAMES	291
public static final int	NATIONAL	292
public static final int	NATURAL	293
public static final int	NCHAR	294
public static final int	NCLOB	295
public static final int	NE	587
public static final int	NE2	588
public static final int	NESTING	296
public static final int	NEW	297
public static final int	NEXT	298
public static final int	NO	299
public static final int	NONE	300
public static final int	NORMALIZE	301
public static final int	NORMALIZED	302
public static final int	NOT	303
public static final int	NULL	304
public static final int	NULLABLE	305
public static final int	NULLIF	306
public static final int	NULLS	307
public static final int	NUMBER	308
public static final int	NUMERIC	309
public static final int	OBJECT	310
public static final int	OCTET_LENGTH	311
public static final int	OCTETS	312
public static final int	OF	313
public static final int	OFFSET	314
public static final int	OLD	315
public static final int	ON	316
public static final int	ONLY	317
public static final int	OPEN	318
public static final int	OPTION	319
public static final int	OPTIONS	320
public static final int	OR	321
public static final int	ORDER	322
public static final int	ORDERING	323
public static final int	ORDINALITY	324
public static final int	OTHERS	325
public static final int	OUT	326
public static final int	OUTER	327
public static final int	OUTPUT	328
public static final int	OUTPUTFORMAT	551
public static final int	OVER	329
public static final int	OVERLAPS	330
public static final int	OVERLAY	331
public static final int	OVERRIDING	332
public static final int	PAD	333
public static final int	PARAMETER	334
public static final int	PARAMETER_MODE	335
public static final int	PARAMETER_NAME	336
public static final int	PARAMETER_ORDINAL_POSITION	337
public static final int	PARAMETER_SPECIFIC_CATALOG	338
public static final int	PARAMETER_SPECIFIC_NAME	339
public static final int	PARAMETER_SPECIFIC_SCHEMA	340
public static final int	PARTIAL	341
public static final int	PARTITION	342
public static final int	PASCAL	343
public static final int	PASSTHROUGH	344
public static final int	PATH	345
public static final int	PERCENT_RANK	346
public static final int	PERCENTILE_CONT	347
public static final int	PERCENTILE_DISC	348
public static final int	PLACING	349
public static final int	PLAN	350
public static final int	PLI	351
public static final int	PLUS	589
public static final int	POSITION	352
public static final int	POWER	353
public static final int	PRECEDING	354
public static final int	PRECISION	355
public static final int	PREFIXED_STRING_LITERAL	563
public static final int	PREPARE	356
public static final int	PRESERVE	357
public static final int	PRIMARY	358
public static final int	PRIOR	359
public static final int	PRIVILEGES	360
public static final int	PROCEDURE	361
public static final int	PUBLIC	362
public static final int	QUARTER	363
public static final int	QUOTE	596
public static final int	QUOTED_IDENTIFIER	610
public static final int	QUOTED_STRING	562
public static final int	RANGE	364
public static final int	RANK	365
public static final int	RBRACE	574
public static final int	RBRACKET	576
public static final int	READ	366
public static final int	READS	367
public static final int	REAL	368
public static final int	RECURSIVE	369
public static final int	REF	370
public static final int	REFERENCES	371
public static final int	REFERENCING	372
public static final int	REGR_AVGX	373
public static final int	REGR_AVGY	374
public static final int	REGR_COUNT	375
public static final int	REGR_INTERCEPT	376
public static final int	REGR_R2	377
public static final int	REGR_SLOPE	378
public static final int	REGR_SXX	379
public static final int	REGR_SXY	380
public static final int	REGR_SYY	381
public static final int	RELATIVE	382
public static final int	RELEASE	383
public static final int	REPEATABLE	384
public static final int	RESET	385
public static final int	RESTART	386
public static final int	RESTRICT	387
public static final int	RESULT	388
public static final int	RETURN	389
public static final int	RETURNED_CARDINALITY	390
public static final int	RETURNED_LENGTH	391
public static final int	RETURNED_OCTET_LENGTH	392
public static final int	RETURNED_SQLSTATE	393
public static final int	RETURNS	394
public static final int	REVOKE	395
public static final int	RIGHT	396
public static final int	ROLE	397
public static final int	ROLLBACK	398
public static final int	ROLLUP	399
public static final int	ROUTINE	400
public static final int	ROUTINE_CATALOG	401
public static final int	ROUTINE_NAME	402
public static final int	ROUTINE_SCHEMA	403
public static final int	ROW	404
public static final int	ROW_COUNT	405
public static final int	ROW_NUMBER	406
public static final int	ROWS	407
public static final int	RPAREN	568
public static final int	SAVEPOINT	408
public static final int	SCALE	409
public static final int	SCHEMA	410
public static final int	SCHEMA_NAME	411
public static final int	SCOPE	412
public static final int	SCOPE_CATALOGS	413
public static final int	SCOPE_NAME	414
public static final int	SCOPE_SCHEMA	415
public static final int	SCROLL	416
public static final int	SEARCH	417
public static final int	SECOND	418
public static final int	SECTION	419
public static final int	SECURITY	420
public static final int	SELECT	421
public static final int	SELF	422
public static final int	SEMICOLON	577
public static final int	SENSITIVE	423
public static final int	SEQUENCE	424
public static final int	SERIALIZABLE	425
public static final int	SERVER	426
public static final int	SERVER_NAME	427
public static final int	SESSION	428
public static final int	SESSION_USER	429
public static final int	SET	430
public static final int	SETS	431
public static final int	SIMILAR	432
public static final int	SIMPLE	433
public static final int	SINGLE_LINE_COMMENT	605
public static final int	SIZE	434
public static final int	SLASH	592
public static final int	SMALLINT	435
public static final int	SOME	436
public static final int	SOURCE	437
public static final int	SPACE	438
public static final int	SPECIFIC	439
public static final int	SPECIFIC_NAME	440
public static final int	SPECIFICTYPE	441
public static final int	SQL	442
public static final int	SQL_TSI_DAY	446
public static final int	SQL_TSI_FRAC_SECOND	447
public static final int	SQL_TSI_HOUR	448
public static final int	SQL_TSI_MICROSECOND	449
public static final int	SQL_TSI_MINUTE	450
public static final int	SQL_TSI_MONTH	451
public static final int	SQL_TSI_QUARTER	452
public static final int	SQL_TSI_SECOND	453
public static final int	SQL_TSI_WEEK	454
public static final int	SQL_TSI_YEAR	455
public static final int	SQLEXCEPTION	443
public static final int	SQLSTATE	444
public static final int	SQLWARNING	445
public static final int	SQRT	456
public static final int	STAR	591
public static final int	START	457
public static final int	STATE	458
public static final int	STATEMENT	459
public static final int	STATIC	460
public static final int	STDDEV_POP	461
public static final int	STDDEV_SAMP	462
public static final int	STORED	552
public static final int	STREAM	463
public static final int	STRUCTURE	464
public static final int	STYLE	465
public static final int	SUBCLASS_ORIGIN	466
public static final int	SUBMULTISET	467
public static final int	SUBSTITUTE	469
public static final int	SUBSTRING	468
public static final int	SUM	470
public static final int	SYMMETRIC	471
public static final int	SYSTEM	472
public static final int	SYSTEM_USER	473
public static final int	TABLE	474
public static final int	TABLE_NAME	475
public static final int	TABLESAMPLE	476
public static final int	TBLPROPERTIES	553
public static final int	TEMPORARY	477
public static final int	THEN	478
public static final int	TIES	479
public static final int	TIME	480
public static final int	TIMESTAMP	481
public static final int	TIMESTAMPADD	482
public static final int	TIMESTAMPDIFF	483
public static final int	TIMEZONE_HOUR	484
public static final int	TIMEZONE_MINUTE	485
public static final int	TINYINT	486
public static final int	TO	487
public static final int	TOP_LEVEL_COUNT	488
public static final int	TRAILING	489
public static final int	TRANSACTION	490
public static final int	TRANSACTIONS_ACTIVE	491
public static final int	TRANSACTIONS_COMMITTED	492
public static final int	TRANSACTIONS_ROLLED_BACK	493
public static final int	TRANSFORM	494
public static final int	TRANSFORMS	495
public static final int	TRANSLATE	496
public static final int	TRANSLATION	497
public static final int	TREAT	498
public static final int	TRIGGER	499
public static final int	TRIGGER_CATALOG	500
public static final int	TRIGGER_NAME	501
public static final int	TRIGGER_SCHEMA	502
public static final int	TRIM	503
public static final int	TRUE	504
public static final int	TYPE	505
public static final int	UESCAPE	506
public static final int	UNBOUNDED	507
public static final int	UNCOMMITTED	508
public static final int	UNDER	509
public static final int	UNICODE_QUOTED_ESCAPE_CHAR	566
public static final int	UNICODE_QUOTED_IDENTIFIER	614
public static final int	UNICODE_STRING_LITERAL	564
public static final int	UNION	510
public static final int	UNIQUE	511
public static final int	UNKNOWN	512
public static final int	UNNAMED	513
public static final int	UNNEST	514
public static final int	UNSIGNED_INTEGER_LITERAL	555
public static final int	UPDATE	515
public static final int	UPPER	516
public static final int	UPSERT	517
public static final int	USAGE	518
public static final int	USER	519
public static final int	USER_DEFINED_TYPE_CATALOG	520
public static final int	USER_DEFINED_TYPE_CODE	521
public static final int	USER_DEFINED_TYPE_NAME	522
public static final int	USER_DEFINED_TYPE_SCHEMA	523
public static final int	USING	524
public static final int	VALUE	525
public static final int	VALUES	526
public static final int	VAR_POP	527
public static final int	VAR_SAMP	528
public static final int	VARBINARY	530
public static final int	VARCHAR	529
public static final int	VARYING	531
public static final int	VERSION	532
public static final int	VIEW	533
public static final int	WEEK	534
public static final int	WHEN	535
public static final int	WHENEVER	536
public static final int	WHERE	537
public static final int	WHITESPACE	560
public static final int	WIDTH_BUCKET	538
public static final int	WINDOW	539
public static final int	WITH	540
public static final int	WITHIN	541
public static final int	WITHOUT	542
public static final int	WORK	543
public static final int	WRAPPER	544
public static final int	WRITE	545
public static final int	XML	546
public static final int	YEAR	547
public static final int	ZONE	548

org.apache.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

org.apache.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

org.apache.storm.stats.BoltExecutorStats

Modifier and Type	Constant Field	Value
public static final String	ACKED	"acked"
public static final String	EXECUTE_LATENCIES	"execute-latencies"
public static final String	EXECUTED	"executed"
public static final String	FAILED	"failed"
public static final String	PROCESS_LATENCIES	"process-latencies"

org.apache.storm.stats.CommonStats

Modifier and Type	Constant Field	Value
public static final String	EMITTED	"emitted"
public static final int	NUM_STAT_BUCKETS	20
public static final String	RATE	"rate"
public static final String	TRANSFERRED	"transferred"

org.apache.storm.stats.SpoutExecutorStats

Modifier and Type	Constant Field	Value
public static final String	ACKED	"acked"
public static final String	COMPLETE_LATENCIES	"complete-latencies"
public static final String	FAILED	"failed"

org.apache.storm.stats.StatsUtil

Modifier and Type	Constant Field	Value
public static final String	BOLT	"bolt"
public static final String	SPOUT	"spout"
public static final int	TEN_MIN_IN_SECONDS	600
public static final String	TEN_MIN_IN_SECONDS_STR	"600"
public static final String	TYPE	"type"

org.apache.storm.task.ShellBolt

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

org.apache.storm.task.WorkerTopologyContext

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

org.apache.storm.topology.WindowedBoltExecutor

Modifier and Type	Constant Field	Value
public static final String	LATE_TUPLE_FIELD	"late_tuple"

org.apache.storm.trident.spout.RichSpoutBatchExecutor

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

org.apache.storm.trident.spout.TridentSpoutExecutor

Modifier and Type	Constant Field	Value
public static final String	ID_FIELD	"$tx"

org.apache.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"

org.apache.storm.trident.topology.TridentBoltExecutor

Modifier and Type	Constant Field	Value
public static final String	COORD_STREAM_PREFIX	"$coord-"

org.apache.storm.trident.windowing.WindowsStore

Modifier and Type	Constant Field	Value
public static final String	KEY_SEPARATOR	"|"

org.apache.storm.trident.windowing.WindowTridentProcessor

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_INMEMORY_TUPLE_CACHE_LIMIT	100L
public static final String	TRIGGER_COUNT_PREFIX	"tc|"
public static final String	TRIGGER_FIELD_NAME	"_task_info"
public static final String	TRIGGER_INPROCESS_PREFIX	"tip|"
public static final String	TRIGGER_PREFIX	"tr|"

org.apache.storm.tuple.AddressedTuple

Modifier and Type	Constant Field	Value
public static final int	BROADCAST_DEST	-2

org.apache.storm.utils.ConfigUtils

Modifier and Type	Constant Field	Value
public static final String	NIMBUS_DO_NOT_REASSIGN	"NIMBUS-DO-NOT-REASSIGN"
public static final String	RESOURCES_SUBDIR	"resources"

org.apache.storm.utils.LocalState

Modifier and Type	Constant Field	Value
public static final String	LS_APPROVED_WORKERS	"approved-workers"
public static final String	LS_ID	"supervisor-id"
public static final String	LS_LOCAL_ASSIGNMENTS	"local-assignments"
public static final String	LS_TOPO_HISTORY	"topo-hist"
public static final String	LS_WORKER_HEARTBEAT	"worker-heartbeat"

org.apache.storm.utils.Utils

Modifier and Type	Constant Field	Value
public static final String	CURRENT_BLOB_SUFFIX_ID	"current"
public static final String	DEFAULT_BLOB_VERSION_SUFFIX	".version"
public static final String	DEFAULT_CURRENT_BLOB_SUFFIX	".current"
public static final String	DEFAULT_STREAM_ID	"default"
public static final int	SIGKILL	9
public static final int	SIGTERM	15

org.apache.storm.windowing.WindowManager<T>

Modifier and Type	Constant Field	Value
public static final int	EXPIRE_EVENTS_THRESHOLD	100

storm.starter.*

storm.starter.HdfsSpoutTopology

Modifier and Type	Constant Field	Value
public static final String	BOLT_ID	"constbolt"
public static final String	SPOUT_ID	"hdfsspout"

storm.starter.HdfsSpoutTopology.ConstBolt

Modifier and Type	Constant Field	Value
public static final String	FIELDS	"message"