Constant Field Values

Contents

• org.apache.*

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	BACKPRESSURE_ZNODE_TIMEOUT_SECS	"backpressure.znode.timeout.secs"
public static final String	BACKPRESSURE_ZNODE_UPDATE_FREQ_SECS	"backpressure.znode.update.freq.secs"
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	DEV_ZOOKEEPER_PATH	"dev.zookeeper.path"
public static final String	DISABLE_SYMLINKS	"storm.disable.symlinks"
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_HOST	"pacemaker.host"
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_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_METRICS_REPORTERS	"storm.metrics.reporters"
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_NIMBUS_ZOOKEEPER_ACLS_CHECK	"storm.nimbus.zookeeper.acls.check"
public static final String	STORM_NIMBUS_ZOOKEEPER_ACLS_FIXUP	"storm.nimbus.zookeeper.acls.fixup"
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_SOCKET_TIMEOUT_MS	"storm.thrift.socket.timeout.ms"
public static final String	STORM_THRIFT_TRANSPORT_PLUGIN	"storm.thrift.transport"
public static final String	STORM_TOPOLOGY_SUBMISSION_NOTIFIER_PLUGIN	"storm.topology.submission.notifier.plugin.class"
public static final String	STORM_WORKER_DISRUPTOR_FLUSHER_MAX_POOL_SIZE	"storm.worker.disruptor.flusher.max.pool.size"
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_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_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_EVENT_LOGGER_REGISTER	"topology.event.logger.register"
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_LOG_HANDLER	"topology.multilang.log.handler"
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_HTTP_X_FRAME_OPTIONS	"ui.http.x-frame-options"
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_PAGINATION	"ui.pagination"
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	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"

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_DATACENTER_NAME	"cassandra.datacenter.name"
public static final String	CASSANDRA_HEARTBEAT_INTERVAL_SEC	"cassandra.heartbeat.interval.sec"
public static final String	CASSANDRA_IDLE_TIMEOUT_SEC	"cassandra.idle.timeout.sec"
public static final String	CASSANDRA_KEYSPACE	"cassandra.keyspace"
public static final String	CASSANDRA_LOAD_BALANCING_POLICY	"cassandra.loadBalancingPolicy"
public static final String	CASSANDRA_MAX_REQUESTS_PER_CON_LOCAL	"cassandra.max.requests.per.con.local"
public static final String	CASSANDRA_MAX_REQUESTS_PER_CON_REMOTE	"cassandra.max.requests.per.con.remote"
public static final String	CASSANDRA_NODES	"cassandra.nodes"
public static final String	CASSANDRA_PASSWORD	"cassandra.password"
public static final String	CASSANDRA_POOL_MAX_SIZE	"cassandra.pool.max.size"
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_SOCKET_CONNECT_TIMEOUT_MS	"cassandra.socket.connect.timeout.millis"
public static final String	CASSANDRA_SOCKET_READ_TIMEOUT_MS	"cassandra.socket.read.timeout.millis"
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	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.common.AbstractAutoCreds

Modifier and Type	Constant Field	Value
public static final String	CONFIG_KEY_RESOURCES	"resources"

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.common.Utils

Modifier and Type	Constant Field	Value
public static final String	TOKEN_KIND_HBASE_AUTH_TOKEN	"HBASE_AUTH_TOKEN"

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	HBASE_CREDENTIALS_CONFIG_KEYS	"hbaseCredentialsConfigKeys"
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.state.HBaseKeyValueState<K,V>

Modifier and Type	Constant Field	Value
public static final int	ITERATOR_CHUNK_SIZE	1000

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.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.security.HdfsSecurityUtil

Modifier and Type	Constant Field	Value
public static final String	HDFS_CREDENTIALS_CONFIG_KEYS	"hdfsCredentialsConfigKeys"
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.HdfsSpoutTopology

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

org.apache.storm.hdfs.spout.HdfsSpoutTopology.ConstBolt

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

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.hive.common.HiveOptions

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_TICK_TUPLE_INTERVAL_SECS	15

org.apache.storm.hive.security.AutoHive

Modifier and Type	Constant Field	Value
public static final String	HIVE_CREDENTIALS	"HIVE_CREDENTIALS"
public static final String	HIVE_CREDENTIALS_CONFIG_KEYS	"hiveCredentialsConfigKeys"
public static final String	HIVE_KEYTAB_FILE_KEY	"hive.keytab.file"
public static final String	HIVE_PRINCIPAL_KEY	"hive.kerberos.principal"

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.KafkaSpout<K,V>

Modifier and Type	Constant Field	Value
public static final long	TIMER_DELAY_MS	500L

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 int	DEFAULT_METRICS_TIME_BUCKET_SIZE_SECONDS	60
public static final long	DEFAULT_OFFSET_COMMIT_PERIOD_MS	30000L
public static final long	DEFAULT_PARTITION_REFRESH_PERIOD_MS	2000L
public static final long	DEFAULT_POLL_TIMEOUT_MS	200L

org.apache.storm.kafka.spout.trident.KafkaTridentSpoutBatchMetadata

Modifier and Type	Constant Field	Value
public static final String	FIRST_OFFSET_KEY	"firstOffset"
public static final String	LAST_OFFSET_KEY	"lastOffset"
public static final String	TOPIC_PARTITION_KEY	"tp"

org.apache.storm.kafka.spout.trident.TopicPartitionSerializer

Modifier and Type	Constant Field	Value
public static final String	TOPIC_PARTITION_PARTITION_KEY	"partition"
public static final String	TOPIC_PARTITION_TOPIC_KEY	"topic"

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"
public static final String	TOPOLOGY_EVENT_LOGGER_ARGUMENTS	"arguments"
public static final String	TOPOLOGY_EVENT_LOGGER_CLASS	"class"

org.apache.storm.metrics2.reporters.CsvStormReporter

Modifier and Type	Constant Field	Value
public static final String	CSV_LOG_DIR	"csv.log.dir"

org.apache.storm.metrics2.reporters.GraphiteStormReporter

Modifier and Type	Constant Field	Value
public static final String	GRAPHITE_HOST	"graphite.host"
public static final String	GRAPHITE_PORT	"graphite.port"
public static final String	GRAPHITE_PREFIXED_WITH	"graphite.prefixed.with"
public static final String	GRAPHITE_TRANSPORT	"graphite.transport"

org.apache.storm.metrics2.reporters.JmxStormReporter

Modifier and Type	Constant Field	Value
public static final String	JMX_DOMAIN	"jmx.domain"

org.apache.storm.metrics2.reporters.StormReporter

Modifier and Type	Constant Field	Value
public static final String	REPORT_PERIOD	"report.period"
public static final String	REPORT_PERIOD_UNITS	"report.period.units"

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.perf.ConstSpoutIdBoltNullBoltTopo

Modifier and Type	Constant Field	Value
public static final String	BOLT1_COUNT	"bolt1.count"
public static final String	BOLT1_ID	"idBolt"
public static final String	BOLT2_COUNT	"bolt2.count"
public static final String	BOLT2_ID	"nullBolt"
public static final String	SPOUT_COUNT	"spout.count"
public static final String	SPOUT_ID	"constSpout"
public static final String	TOPOLOGY_NAME	"ConstSpoutIdBoltNullBoltTopo"

org.apache.storm.perf.ConstSpoutNullBoltTopo

Modifier and Type	Constant Field	Value
public static final String	BOLT_COUNT	"bolt.count"
public static final String	BOLT_ID	"nullBolt"
public static final String	DEFAULT_GROUPING	"local"
public static final String	GROUPING	"grouping"
public static final String	LOCAL_GROPING	"local"
public static final String	SHUFFLE_GROUPING	"shuffle"
public static final String	SPOUT_COUNT	"spout.count"
public static final String	SPOUT_ID	"constSpout"
public static final String	TOPOLOGY_NAME	"ConstSpoutNullBoltTopo"

org.apache.storm.perf.ConstSpoutOnlyTopo

Modifier and Type	Constant Field	Value
public static final String	SPOUT_ID	"constSpout"
public static final String	TOPOLOGY_NAME	"ConstSpoutOnlyTopo"

org.apache.storm.perf.FileReadWordCountTopo

Modifier and Type	Constant Field	Value
public static final String	COUNT_ID	"counter"
public static final String	COUNT_NUM	"counter.count"
public static final int	DEFAULT_COUNT_BOLT_NUM	2
public static final int	DEFAULT_SPLIT_BOLT_NUM	2
public static final int	DEFAULT_SPOUT_NUM	1
public static final String	INPUT_FILE	"input.file"
public static final String	SPLIT_ID	"splitter"
public static final String	SPLIT_NUM	"splitter.count"
public static final String	SPOUT_ID	"spout"
public static final String	SPOUT_NUM	"spout.count"
public static final String	TOPOLOGY_NAME	"FileReadWordCountTopo"

org.apache.storm.perf.HdfsSpoutNullBoltTopo

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_BOLT_NUM	1
public static final int	DEFAULT_SPOUT_NUM	1

org.apache.storm.perf.KafkaHdfsTopo

Modifier and Type	Constant Field	Value
public static final String	BOLT_ID	"hdfsBolt"
public static final String	BOLT_NUM	"bolt.count"
public static final int	DEFAULT_BOLT_NUM	1
public static final int	DEFAULT_HDFS_BATCH	1000
public static final int	DEFAULT_SPOUT_NUM	1
public static final String	HDFS_BATCH	"hdfs.batch"
public static final String	HDFS_PATH	"hdfs.dir"
public static final String	HDFS_URI	"hdfs.uri"
public static final String	KAFKA_TOPIC	"kafka.topic"
public static final String	SPOUT_ID	"kafkaSpout"
public static final String	SPOUT_NUM	"spout.count"
public static final String	TOPOLOGY_NAME	"KafkaHdfsTopo"
public static final String	ZOOKEEPER_URI	"zk.uri"

org.apache.storm.perf.KafkaSpoutNullBoltTopo

Modifier and Type	Constant Field	Value
public static final String	BOLT_ID	"devNullBolt"
public static final String	BOLT_NUM	"bolt.count"
public static final int	DEFAULT_BOLT_NUM	1
public static final int	DEFAULT_SPOUT_NUM	1
public static final String	KAFKA_TOPIC	"kafka.topic"
public static final String	SPOUT_ID	"kafkaSpout"
public static final String	SPOUT_NUM	"spout.count"
public static final String	TOPOLOGY_NAME	"KafkaSpoutNullBoltTopo"
public static final String	ZOOKEEPER_URI	"zk.uri"

org.apache.storm.perf.StrGenSpoutHdfsBoltTopo

Modifier and Type	Constant Field	Value
public static final String	BOLT_ID	"hdfsBolt"
public static final String	BOLT_NUM	"bolt.count"
public static final int	DEFAULT_BOLT_NUM	1
public static final int	DEFAULT_HDFS_BATCH	1000
public static final int	DEFAULT_SPOUT_NUM	1
public static final String	HDFS_BATCH	"hdfs.batch"
public static final String	HDFS_PATH	"hdfs.dir"
public static final String	HDFS_URI	"hdfs.uri"
public static final String	SPOUT_ID	"GenSpout"
public static final String	SPOUT_NUM	"spout.count"
public static final String	TOPOLOGY_NAME	"StrGenSpoutHdfsBoltTopo"

org.apache.storm.perf.bolt.CountBolt

Modifier and Type	Constant Field	Value
public static final String	FIELDS_COUNT	"count"
public static final String	FIELDS_WORD	"word"

org.apache.storm.perf.bolt.SplitSentenceBolt

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

org.apache.storm.perf.spout.FileReadSpout

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

org.apache.storm.perf.utils.BasicMetricsCollector

Modifier and Type	Constant Field	Value
public static final String	EXECUTORS	"executors"
public static final String	SPOUT_ACKED	"spout_acks"
public static final String	SPOUT_AVG_COMPLETE_LATENCY	"spout_avg_complete_latency(ms)"
public static final String	SPOUT_AVG_LATENCY_FORMAT	"%.1f"
public static final String	SPOUT_EXECUTORS	"spout_executors"
public static final String	SPOUT_MAX_COMPLETE_LATENCY	"spout_max_complete_latency(ms)"
public static final String	SPOUT_MAX_LATENCY_FORMAT	"%.1f"
public static final String	SPOUT_THROUGHPUT	"spout_throughput (acks/s)"
public static final String	SPOUT_TRANSFERRED	"spout_transferred (messages)"
public static final String	TASKS	"tasks"
public static final String	TIME	"elapsed (sec)"
public static final String	TIME_FORMAT	"%d"
public static final String	TOTAL_SLOTS	"total_slots"
public static final String	TRANSFERRED	"transferred (messages)"
public static final String	USED_SLOTS	"used_slots"
public static final String	WORKERS	"workers"
public static final String	XSFER_RATE	"transfer rate (messages/s)"

org.apache.storm.redis.state.RedisKeyValueState<K,V>

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

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.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	APPLY	591
public static final int	APPROX_NUMERIC_LITERAL	600
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	655
public static final int	BEFORE	30
public static final int	BEGIN	31
public static final int	BEL	661
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	605
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	653
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	609
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	656
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	628
public static final int	COLUMN	77
public static final int	COLUMN_NAME	78
public static final int	COMMA	623
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	637
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	601
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	660
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	622
public static final int	DOUBLE	154
public static final int	DOUBLE_PERIOD	639
public static final int	DOUBLE_QUOTE	641
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	624
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	602
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	650
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	630
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	625
public static final int	HAVING	212
public static final int	HEXDIGIT	603
public static final int	HIERARCHY	213
public static final int	HOLD	214
public static final int	HOOK	627
public static final int	HOUR	215
public static final int	IDENTIFIER	657
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	593
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	598
public static final int	JAVA	241
public static final int	JOIN	242
public static final int	JSON	243
public static final int	K	244
public static final int	KEY	245
public static final int	KEY_MEMBER	246
public static final int	KEY_TYPE	247
public static final int	LABEL	248
public static final int	LANGUAGE	249
public static final int	LARGE	250
public static final int	LAST	251
public static final int	LAST_VALUE	252
public static final int	LATERAL	253
public static final int	LBRACE	617
public static final int	LBRACE_D	613
public static final int	LBRACE_FN	616
public static final int	LBRACE_T	614
public static final int	LBRACE_TS	615
public static final int	LBRACKET	619
public static final int	LE	629
public static final int	LEADING	254
public static final int	LEFT	255
public static final int	LENGTH	256
public static final int	LETTER	659
public static final int	LEVEL	257
public static final int	LIBRARY	258
public static final int	LIKE	259
public static final int	LIMIT	260
public static final int	LN	261
public static final int	LOCAL	262
public static final int	LOCALTIME	263
public static final int	LOCALTIMESTAMP	264
public static final int	LOCATION	592
public static final int	LOCATOR	265
public static final int	LOWER	266
public static final int	LPAREN	611
public static final int	LT	626
public static final int	M	267
public static final int	MAP	268
public static final int	MATCH	269
public static final int	MATCHED	270
public static final int	MAX	271
public static final int	MAXVALUE	272
public static final int	MEMBER	273
public static final int	MERGE	274
public static final int	MESSAGE_LENGTH	275
public static final int	MESSAGE_OCTET_LENGTH	276
public static final int	MESSAGE_TEXT	277
public static final int	METHOD	278
public static final int	MICROSECOND	279
public static final int	MILLENNIUM	280
public static final int	MIN	281
public static final int	MINUS	634
public static final int	MINUTE	282
public static final int	MINVALUE	283
public static final int	MOD	284
public static final int	MODIFIES	285
public static final int	MODULE	286
public static final int	MONTH	287
public static final int	MORE_KW	288
public static final int	MULTI_LINE_COMMENT	651
public static final int	MULTISET	289
public static final int	MUMPS	290
public static final int	NAME	291
public static final int	NAMED_ARGUMENT_ASSIGNMENT	638
public static final int	NAMES	292
public static final int	NATIONAL	293
public static final int	NATURAL	294
public static final int	NCHAR	295
public static final int	NCLOB	296
public static final int	NE	631
public static final int	NE2	632
public static final int	NESTING	297
public static final int	NEW	298
public static final int	NEXT	299
public static final int	NO	300
public static final int	NONE	301
public static final int	NORMALIZE	302
public static final int	NORMALIZED	303
public static final int	NOT	304
public static final int	NULL	305
public static final int	NULLABLE	306
public static final int	NULLIF	307
public static final int	NULLS	308
public static final int	NUMBER	309
public static final int	NUMERIC	310
public static final int	OBJECT	311
public static final int	OCTET_LENGTH	312
public static final int	OCTETS	313
public static final int	OF	314
public static final int	OFFSET	315
public static final int	OLD	316
public static final int	ON	317
public static final int	ONLY	318
public static final int	OPEN	319
public static final int	OPTION	320
public static final int	OPTIONS	321
public static final int	OR	322
public static final int	ORDER	323
public static final int	ORDERING	324
public static final int	ORDINALITY	325
public static final int	OTHERS	326
public static final int	OUT	327
public static final int	OUTER	328
public static final int	OUTPUT	329
public static final int	OUTPUTFORMAT	594
public static final int	OVER	330
public static final int	OVERLAPS	331
public static final int	OVERLAY	332
public static final int	OVERRIDING	333
public static final int	PAD	334
public static final int	PARALLELISM	595
public static final int	PARAMETER	335
public static final int	PARAMETER_MODE	336
public static final int	PARAMETER_NAME	337
public static final int	PARAMETER_ORDINAL_POSITION	338
public static final int	PARAMETER_SPECIFIC_CATALOG	339
public static final int	PARAMETER_SPECIFIC_NAME	340
public static final int	PARAMETER_SPECIFIC_SCHEMA	341
public static final int	PARTIAL	342
public static final int	PARTITION	343
public static final int	PASCAL	344
public static final int	PASSTHROUGH	345
public static final int	PATH	346
public static final int	PERCENT_RANK	347
public static final int	PERCENTILE_CONT	348
public static final int	PERCENTILE_DISC	349
public static final int	PLACING	350
public static final int	PLAN	351
public static final int	PLI	352
public static final int	PLUS	633
public static final int	POSITION	353
public static final int	POWER	354
public static final int	PRECEDING	355
public static final int	PRECISION	356
public static final int	PREFIXED_STRING_LITERAL	607
public static final int	PREPARE	357
public static final int	PRESERVE	358
public static final int	PRIMARY	359
public static final int	PRIOR	360
public static final int	PRIVILEGES	361
public static final int	PROCEDURE	362
public static final int	PUBLIC	363
public static final int	QUARTER	364
public static final int	QUOTE	640
public static final int	QUOTED_IDENTIFIER	654
public static final int	QUOTED_STRING	606
public static final int	RANGE	365
public static final int	RANK	366
public static final int	RBRACE	618
public static final int	RBRACKET	620
public static final int	READ	367
public static final int	READS	368
public static final int	REAL	369
public static final int	RECURSIVE	370
public static final int	REF	371
public static final int	REFERENCES	372
public static final int	REFERENCING	373
public static final int	REGR_AVGX	374
public static final int	REGR_AVGY	375
public static final int	REGR_COUNT	376
public static final int	REGR_INTERCEPT	377
public static final int	REGR_R2	378
public static final int	REGR_SLOPE	379
public static final int	REGR_SXX	380
public static final int	REGR_SXY	381
public static final int	REGR_SYY	382
public static final int	RELATIVE	383
public static final int	RELEASE	384
public static final int	REPEATABLE	385
public static final int	REPLACE	386
public static final int	RESET	387
public static final int	RESTART	388
public static final int	RESTRICT	389
public static final int	RESULT	390
public static final int	RETURN	391
public static final int	RETURNED_CARDINALITY	392
public static final int	RETURNED_LENGTH	393
public static final int	RETURNED_OCTET_LENGTH	394
public static final int	RETURNED_SQLSTATE	395
public static final int	RETURNS	396
public static final int	REVOKE	397
public static final int	RIGHT	398
public static final int	ROLE	399
public static final int	ROLLBACK	400
public static final int	ROLLUP	401
public static final int	ROUTINE	402
public static final int	ROUTINE_CATALOG	403
public static final int	ROUTINE_NAME	404
public static final int	ROUTINE_SCHEMA	405
public static final int	ROW	406
public static final int	ROW_COUNT	407
public static final int	ROW_NUMBER	408
public static final int	ROWS	409
public static final int	RPAREN	612
public static final int	SAVEPOINT	410
public static final int	SCALE	411
public static final int	SCHEMA	412
public static final int	SCHEMA_NAME	413
public static final int	SCOPE	414
public static final int	SCOPE_CATALOGS	415
public static final int	SCOPE_NAME	416
public static final int	SCOPE_SCHEMA	417
public static final int	SCROLL	418
public static final int	SEARCH	419
public static final int	SECOND	420
public static final int	SECTION	421
public static final int	SECURITY	422
public static final int	SELECT	423
public static final int	SELF	424
public static final int	SEMICOLON	621
public static final int	SENSITIVE	425
public static final int	SEQUENCE	426
public static final int	SERIALIZABLE	427
public static final int	SERVER	428
public static final int	SERVER_NAME	429
public static final int	SESSION	430
public static final int	SESSION_USER	431
public static final int	SET	432
public static final int	SET_MINUS	434
public static final int	SETS	433
public static final int	SIMILAR	435
public static final int	SIMPLE	436
public static final int	SINGLE_LINE_COMMENT	649
public static final int	SIZE	437
public static final int	SLASH	636
public static final int	SMALLINT	438
public static final int	SOME	439
public static final int	SOURCE	440
public static final int	SPACE	441
public static final int	SPECIFIC	442
public static final int	SPECIFIC_NAME	443
public static final int	SPECIFICTYPE	444
public static final int	SQL	445
public static final int	SQL_BIGINT	449
public static final int	SQL_BINARY	450
public static final int	SQL_BIT	451
public static final int	SQL_BLOB	452
public static final int	SQL_BOOLEAN	453
public static final int	SQL_CHAR	454
public static final int	SQL_CLOB	455
public static final int	SQL_DATE	456
public static final int	SQL_DECIMAL	457
public static final int	SQL_DOUBLE	458
public static final int	SQL_FLOAT	459
public static final int	SQL_INTEGER	460
public static final int	SQL_INTERVAL_DAY	461
public static final int	SQL_INTERVAL_DAY_TO_HOUR	462
public static final int	SQL_INTERVAL_DAY_TO_MINUTE	463
public static final int	SQL_INTERVAL_DAY_TO_SECOND	464
public static final int	SQL_INTERVAL_HOUR	465
public static final int	SQL_INTERVAL_HOUR_TO_MINUTE	466
public static final int	SQL_INTERVAL_HOUR_TO_SECOND	467
public static final int	SQL_INTERVAL_MINUTE	468
public static final int	SQL_INTERVAL_MINUTE_TO_SECOND	469
public static final int	SQL_INTERVAL_MONTH	470
public static final int	SQL_INTERVAL_SECOND	471
public static final int	SQL_INTERVAL_YEAR	472
public static final int	SQL_INTERVAL_YEAR_TO_MONTH	473
public static final int	SQL_LONGVARBINARY	474
public static final int	SQL_LONGVARCHAR	475
public static final int	SQL_LONGVARNCHAR	476
public static final int	SQL_NCHAR	477
public static final int	SQL_NCLOB	478
public static final int	SQL_NUMERIC	479
public static final int	SQL_NVARCHAR	480
public static final int	SQL_REAL	481
public static final int	SQL_SMALLINT	482
public static final int	SQL_TIME	483
public static final int	SQL_TIMESTAMP	484
public static final int	SQL_TINYINT	485
public static final int	SQL_TSI_DAY	486
public static final int	SQL_TSI_FRAC_SECOND	487
public static final int	SQL_TSI_HOUR	488
public static final int	SQL_TSI_MICROSECOND	489
public static final int	SQL_TSI_MINUTE	490
public static final int	SQL_TSI_MONTH	491
public static final int	SQL_TSI_QUARTER	492
public static final int	SQL_TSI_SECOND	493
public static final int	SQL_TSI_WEEK	494
public static final int	SQL_TSI_YEAR	495
public static final int	SQL_VARBINARY	496
public static final int	SQL_VARCHAR	497
public static final int	SQLEXCEPTION	446
public static final int	SQLSTATE	447
public static final int	SQLWARNING	448
public static final int	SQRT	498
public static final int	STAR	635
public static final int	START	499
public static final int	STATE	500
public static final int	STATEMENT	501
public static final int	STATIC	502
public static final int	STDDEV_POP	503
public static final int	STDDEV_SAMP	504
public static final int	STORED	596
public static final int	STREAM	505
public static final int	STRUCTURE	506
public static final int	STYLE	507
public static final int	SUBCLASS_ORIGIN	508
public static final int	SUBMULTISET	509
public static final int	SUBSTITUTE	511
public static final int	SUBSTRING	510
public static final int	SUM	512
public static final int	SYMMETRIC	513
public static final int	SYSTEM	514
public static final int	SYSTEM_USER	515
public static final int	TABLE	516
public static final int	TABLE_NAME	517
public static final int	TABLESAMPLE	518
public static final int	TBLPROPERTIES	597
public static final int	TEMPORARY	519
public static final int	THEN	520
public static final int	TIES	521
public static final int	TIME	522
public static final int	TIMESTAMP	523
public static final int	TIMESTAMPADD	524
public static final int	TIMESTAMPDIFF	525
public static final int	TIMEZONE_HOUR	526
public static final int	TIMEZONE_MINUTE	527
public static final int	TINYINT	528
public static final int	TO	529
public static final int	TOP_LEVEL_COUNT	530
public static final int	TRAILING	531
public static final int	TRANSACTION	532
public static final int	TRANSACTIONS_ACTIVE	533
public static final int	TRANSACTIONS_COMMITTED	534
public static final int	TRANSACTIONS_ROLLED_BACK	535
public static final int	TRANSFORM	536
public static final int	TRANSFORMS	537
public static final int	TRANSLATE	538
public static final int	TRANSLATION	539
public static final int	TREAT	540
public static final int	TRIGGER	541
public static final int	TRIGGER_CATALOG	542
public static final int	TRIGGER_NAME	543
public static final int	TRIGGER_SCHEMA	544
public static final int	TRIM	545
public static final int	TRUE	546
public static final int	TYPE	547
public static final int	UESCAPE	548
public static final int	UNBOUNDED	549
public static final int	UNCOMMITTED	550
public static final int	UNDER	551
public static final int	UNICODE_QUOTED_ESCAPE_CHAR	610
public static final int	UNICODE_QUOTED_IDENTIFIER	658
public static final int	UNICODE_STRING_LITERAL	608
public static final int	UNION	552
public static final int	UNIQUE	553
public static final int	UNKNOWN	554
public static final int	UNNAMED	555
public static final int	UNNEST	556
public static final int	UNSIGNED_INTEGER_LITERAL	599
public static final int	UPDATE	557
public static final int	UPPER	558
public static final int	UPSERT	559
public static final int	USAGE	560
public static final int	USER	561
public static final int	USER_DEFINED_TYPE_CATALOG	562
public static final int	USER_DEFINED_TYPE_CODE	563
public static final int	USER_DEFINED_TYPE_NAME	564
public static final int	USER_DEFINED_TYPE_SCHEMA	565
public static final int	USING	566
public static final int	VALUE	567
public static final int	VALUES	568
public static final int	VAR_POP	569
public static final int	VAR_SAMP	570
public static final int	VARBINARY	572
public static final int	VARCHAR	571
public static final int	VARYING	573
public static final int	VERSION	574
public static final int	VIEW	575
public static final int	WEEK	576
public static final int	WHEN	577
public static final int	WHENEVER	578
public static final int	WHERE	579
public static final int	WHITESPACE	604
public static final int	WIDTH_BUCKET	580
public static final int	WINDOW	581
public static final int	WITH	582
public static final int	WITHIN	583
public static final int	WITHOUT	584
public static final int	WORK	585
public static final int	WRAPPER	586
public static final int	WRITE	587
public static final int	XML	588
public static final int	YEAR	589
public static final int	ZONE	590

org.apache.storm.sql.planner.trident.QueryPlanner

Modifier and Type	Constant Field	Value
public static final int	STORM_REL_CONVERSION_RULES	1

org.apache.storm.sql.planner.trident.rules.TridentScanRule

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_PARALLELISM_HINT	1

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.submit.command.DependencyResolverMain

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_FAILBACK_MAVEN_LOCAL_REPOSITORY_DIRECTORY	"local-repo"

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