Constant Field Values

Contents

• org.apache.*

org.apache.*

org.apache.storm.Config

Modifier and Type	Constant Field	Value
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	CLIENT_BLOBSTORE	"client.blobstore.class"
public static final String	DISABLE_SYMLINKS	"storm.disable.symlinks"
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_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_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	EXECUTOR_METRICS_FREQUENCY_SECS	"executor.metrics.frequency.secs"
public static final String	NIMBUS_ADMINS	"nimbus.admins"
public static final String	NIMBUS_ADMINS_GROUPS	"nimbus.admins.groups"
public static final String	NIMBUS_AUTO_CRED_PLUGINS	"nimbus.autocredential.plugins.classes"
public static final String	NIMBUS_CREDENTIAL_RENEWERS	"nimbus.credential.renewers.classes"
public static final String	NIMBUS_DAEMON_USERS	"nimbus.daemon.users"
public static final String	NIMBUS_GROUPS	"nimbus.groups"
public static final String	NIMBUS_IMPERSONATION_ACL	"nimbus.impersonation.acl"
public static final String	NIMBUS_LOCAL_ASSIGNMENTS_BACKEND_CLASS	"nimbus.local.assignments.backend.class"
public static final String	NIMBUS_QUEUE_SIZE	"nimbus.queue.size"
public static final String	NIMBUS_SCHEDULER_STRATEGY_CLASS_WHITELIST	"nimbus.scheduler.strategy.class.whitelist"
public static final String	NIMBUS_SEEDS	"nimbus.seeds"
public static final String	NIMBUS_SUPERVISOR_USERS	"nimbus.supervisor.users"
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_USERS	"nimbus.users"
public static final String	NUM_STAT_BUCKETS	"num.stat.buckets"
public static final String	PACEMAKER_AUTH_METHOD	"pacemaker.auth.method"
public static final String	PACEMAKER_CLIENT_MAX_THREADS	"pacemaker.client.max.threads"
public static final String	PACEMAKER_PORT	"pacemaker.port"
public static final String	PACEMAKER_SERVERS	"pacemaker.servers"
public static final String	PACEMAKER_THRIFT_MESSAGE_SIZE_MAX	"pacemaker.thrift.message.size.max"
public static final String	STORM_BLOBSTORE_ACL_VALIDATION_ENABLED	"storm.blobstore.acl.validation.enabled"
public static final String	STORM_BLOBSTORE_DEPENDENCY_JAR_UPLOAD_CHUNK_SIZE_BYTES	"storm.blobstore.dependency.jar.upload.chunk.size.bytes"
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_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_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_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_ID	"storm.id"
public static final String	STORM_LOCAL_DIR	"storm.local.dir"
public static final String	STORM_LOCAL_HOSTNAME	"storm.local.hostname"
public static final String	STORM_LOCAL_MODE_ZMQ	"storm.local.mode.zmq"
public static final String	STORM_MESSAGING_NETTY_AUTHENTICATION	"storm.messaging.netty.authentication"
public static final String	STORM_MESSAGING_NETTY_BUFFER_HIGH_WATERMARK	"storm.messaging.netty.buffer.high.watermark"
public static final String	STORM_MESSAGING_NETTY_BUFFER_LOW_WATERMARK	"storm.messaging.netty.buffer.low.watermark"
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_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_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_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_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_DRPC_ACL	"storm.zookeeper.drpcACL"
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_CPU_CAPACITY	"supervisor.cpu.capacity"
public static final String	SUPERVISOR_MEMORY_CAPACITY_MB	"supervisor.memory.capacity.mb"
public static final String	SUPERVISOR_QUEUE_SIZE	"supervisor.queue.size"
public static final String	SUPERVISOR_RESOURCES_MAP	"supervisor.resources.map"
public static final String	SUPERVISOR_RUN_WORKER_AS_USER	"supervisor.run.worker.as.user"
public static final String	SUPERVISOR_THRIFT_MAX_BUFFER_SIZE	"supervisor.thrift.max_buffer_size"
public static final String	SUPERVISOR_THRIFT_PORT	"supervisor.thrift.port"
public static final String	SUPERVISOR_THRIFT_SOCKET_TIMEOUT_MS	"supervisor.thrift.socket.timeout.ms"
public static final String	SUPERVISOR_THRIFT_THREADS	"supervisor.thrift.threads"
public static final String	SUPERVISOR_THRIFT_TRANSPORT_PLUGIN	"supervisor.thrift.transport"
public static final String	SUPERVISOR_WORKER_DEFAULT_VERSION	"supervisor.worker.default.version"
public static final String	SUPERVISOR_WORKER_HEARTBEATS_MAX_TIMEOUT_SECS	"supervisor.worker.heartbeats.max.timeout.secs"
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_TIMEOUT_SECS	"supervisor.worker.timeout.secs"
public static final String	SUPERVISOR_WORKER_VERSION_CLASSPATH_MAP	"supervisor.worker.version.classpath.map"
public static final String	SUPERVISOR_WORKER_VERSION_LOGWRITER_MAP	"supervisor.worker.version.logwriter.map"
public static final String	SUPERVISOR_WORKER_VERSION_MAIN_MAP	"supervisor.worker.version.main.map"
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_CPU_PCORE_PERCENT	"topology.acker.cpu.pcore.percent"
public static final String	TOPOLOGY_ACKER_EXECUTORS	"topology.acker.executors"
public static final String	TOPOLOGY_ACKER_RESOURCES_OFFHEAP_MEMORY_MB	"topology.acker.resources.offheap.memory.mb"
public static final String	TOPOLOGY_ACKER_RESOURCES_ONHEAP_MEMORY_MB	"topology.acker.resources.onheap.memory.mb"
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_CHECK_MILLIS	"topology.backpressure.check.millis"
public static final String	TOPOLOGY_BACKPRESSURE_ENABLE	"topology.backpressure.enable"
public static final String	TOPOLOGY_BACKPRESSURE_WAIT_PARK_MICROSEC	"topology.backpressure.wait.park.microsec"
public static final String	TOPOLOGY_BACKPRESSURE_WAIT_PROGRESSIVE_LEVEL1_COUNT	"topology.backpressure.wait.progressive.level1.count"
public static final String	TOPOLOGY_BACKPRESSURE_WAIT_PROGRESSIVE_LEVEL2_COUNT	"topology.backpressure.wait.progressive.level2.count"
public static final String	TOPOLOGY_BACKPRESSURE_WAIT_PROGRESSIVE_LEVEL3_SLEEP_MILLIS	"topology.backpressure.wait.progressive.level3.sleep.millis"
public static final String	TOPOLOGY_BACKPRESSURE_WAIT_STRATEGY	"topology.backpressure.wait.strategy"
public static final String	TOPOLOGY_BATCH_FLUSH_INTERVAL_MILLIS	"topology.batch.flush.interval.millis"
public static final String	TOPOLOGY_BLOBSTORE_MAP	"topology.blobstore.map"
public static final String	TOPOLOGY_BOLT_WAIT_PARK_MICROSEC	"topology.bolt.wait.park.microsec"
public static final String	TOPOLOGY_BOLT_WAIT_PROGRESSIVE_LEVEL1_COUNT	"topology.bolt.wait.progressive.level1.count"
public static final String	TOPOLOGY_BOLT_WAIT_PROGRESSIVE_LEVEL2_COUNT	"topology.bolt.wait.progressive.level2.count"
public static final String	TOPOLOGY_BOLT_WAIT_PROGRESSIVE_LEVEL3_SLEEP_MILLIS	"topology.bolt.wait.progressive.level3.sleep.millis"
public static final String	TOPOLOGY_BOLT_WAIT_STRATEGY	"topology.bolt.wait.strategy"
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_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_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_MAP	"topology.component.resources.map"
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_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_OVERFLOW_LIMIT	"topology.executor.overflow.limit"
public static final String	TOPOLOGY_EXECUTOR_RECEIVE_BUFFER_SIZE	"topology.executor.receive.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_LOCALITYAWARE_HIGHER_BOUND	"topology.localityaware.higher.bound"
public static final String	TOPOLOGY_LOCALITYAWARE_LOWER_BOUND	"topology.localityaware.lower.bound"
public static final String	TOPOLOGY_LOGGING_CONFIG_FILE	"topology.logging.config"
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_CPU_PCORE_PERCENT	"topology.metrics.consumer.cpu.pcore.percent"
public static final String	TOPOLOGY_METRICS_CONSUMER_REGISTER	"topology.metrics.consumer.register"
public static final String	TOPOLOGY_METRICS_CONSUMER_RESOURCES_OFFHEAP_MEMORY_MB	"topology.metrics.consumer.resources.offheap.memory.mb"
public static final String	TOPOLOGY_METRICS_CONSUMER_RESOURCES_ONHEAP_MEMORY_MB	"topology.metrics.consumer.resources.onheap.memory.mb"
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_PRODUCER_BATCH_SIZE	"topology.producer.batch.size"
public static final String	TOPOLOGY_RAS_CONSTRAINT_MAX_STATE_SEARCH	"topology.ras.constraint.max.state.search"
public static final String	TOPOLOGY_RAS_CONSTRAINT_MAX_TIME_SECS	"topology.ras.constraint.max.time.secs"
public static final String	TOPOLOGY_RAS_CONSTRAINTS	"topology.ras.constraints"
public static final String	TOPOLOGY_READONLY_GROUPS	"topology.readonly.groups"
public static final String	TOPOLOGY_READONLY_USERS	"topology.readonly.users"
public static final String	TOPOLOGY_SCHEDULER_FAVORED_NODES	"topology.scheduler.favored.nodes"
public static final String	TOPOLOGY_SCHEDULER_STRATEGY	"topology.scheduler.strategy"
public static final String	TOPOLOGY_SCHEDULER_UNFAVORED_NODES	"topology.scheduler.unfavored.nodes"
public static final String	TOPOLOGY_SERIALIZED_MESSAGE_SIZE_METRICS	"topology.serialized.message.size.metrics"
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_RECVQ_SKIPS	"topology.spout.recvq.skips"
public static final String	TOPOLOGY_SPOUT_WAIT_PARK_MICROSEC	"topology.spout.wait.park.microsec"
public static final String	TOPOLOGY_SPOUT_WAIT_PROGRESSIVE_LEVEL1_COUNT	"topology.spout.wait.progressive.level1.count"
public static final String	TOPOLOGY_SPOUT_WAIT_PROGRESSIVE_LEVEL2_COUNT	"topology.spout.wait.progressive.level2.count"
public static final String	TOPOLOGY_SPOUT_WAIT_PROGRESSIVE_LEVEL3_SLEEP_MILLIS	"topology.spout.wait.progressive.level3.sleep.millis"
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_KRYO_REGISTER	"topology.state.kryo.register"
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_BATCH_SIZE	"topology.transfer.batch.size"
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_VERSION	"topology.version"
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	WORKER_BLOB_UPDATE_POLL_INTERVAL_SECS	"worker.blob.update.poll.interval.secs"
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"

org.apache.storm.Constants

Modifier and Type	Constant Field	Value
public static final String	COMMON_CPU_RESOURCE_NAME	"cpu.pcore.percent"
public static final String	COMMON_OFFHEAP_MEMORY_RESOURCE_NAME	"offheap.memory.mb"
public static final String	COMMON_ONHEAP_MEMORY_RESOURCE_NAME	"onheap.memory.mb"
public static final String	COMMON_TOTAL_MEMORY_RESOURCE_NAME	"memory.mb"
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 String	SYSTEM_FLUSH_STREAM_ID	"__flush"
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	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.DaemonConfig

Modifier and Type	Constant Field	Value
public static final String	BLACKLIST_SCHEDULER_REPORTER	"blacklist.scheduler.reporter"
public static final String	BLACKLIST_SCHEDULER_RESUME_TIME	"blacklist.scheduler.resume.time.secs"
public static final String	BLACKLIST_SCHEDULER_STRATEGY	"blacklist.scheduler.strategy"
public static final String	BLACKLIST_SCHEDULER_TOLERANCE_COUNT	"blacklist.scheduler.tolerance.count"
public static final String	BLACKLIST_SCHEDULER_TOLERANCE_TIME	"blacklist.scheduler.tolerance.time.secs"
public static final String	DEV_ZOOKEEPER_PATH	"dev.zookeeper.path"
public static final String	DRPC_AUTHORIZER	"drpc.authorizer"
public static final String	DRPC_CHILDOPTS	"drpc.childopts"
public static final String	DRPC_DISABLE_HTTP_BINDING	"drpc.disable.http.binding"
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_REQUEST_TIMEOUT_SECS	"drpc.request.timeout.secs"
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_DISABLE_HTTP_BINDING	"logviewer.disable.http.binding"
public static final String	LOGVIEWER_FILTER	"logviewer.filter"
public static final String	LOGVIEWER_FILTER_PARAMS	"logviewer.filter.params"
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_ASSIGNMENTS_SERVICE_THREAD_QUEUE_SIZE	"nimbus.assignments.service.thread.queue.size"
public static final String	NIMBUS_ASSIGNMENTS_SERVICE_THREADS	"nimbus.assignments.service.threads"
public static final String	NIMBUS_AUTHORIZER	"nimbus.authorizer"
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_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_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_SLOTS_PER_TOPOLOGY	"nimbus.slots.perTopology"
public static final String	NIMBUS_SUPERVISOR_TIMEOUT_SECS	"nimbus.supervisor.timeout.secs"
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_TOPOLOGY_ACTION_NOTIFIER_PLUGIN	"nimbus.topology.action.notifier.plugin.class"
public static final String	NIMBUS_TOPOLOGY_BLOBSTORE_DELETION_DELAY_MS	"nimbus.topology.blobstore.deletion.delay.ms"
public static final String	NIMBUS_TOPOLOGY_VALIDATOR	"nimbus.topology.validator"
public static final String	NIMBUS_WORKER_HEARTBEATS_RECOVERY_STRATEGY_CLASS	"nimbus.worker.heartbeats.recovery.strategy.class"
public static final String	PACEMAKER_CHILDOPTS	"pacemaker.childopts"
public static final String	PACEMAKER_MAX_THREADS	"pacemaker.max.threads"
public static final String	RESOURCE_AWARE_SCHEDULER_MAX_STATE_SEARCH	"resource.aware.scheduler.constraint.max.state.search"
public static final String	RESOURCE_AWARE_SCHEDULER_MAX_TOPOLOGY_SCHEDULING_ATTEMPTS	"resource.aware.scheduler.max.topology.scheduling.attempts"
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_CONFIG_LOADER_ARTIFACTORY_BASE_DIRECTORY	"scheduler.config.loader.artifactory.base.directory"
public static final String	SCHEDULER_CONFIG_LOADER_POLLTIME_SECS	"scheduler.config.loader.polltime.secs"
public static final String	SCHEDULER_CONFIG_LOADER_TIMEOUT_SECS	"scheduler.config.loader.timeout.secs"
public static final String	SCHEDULER_CONFIG_LOADER_URI	"scheduler.config.loader.uri"
public static final String	SCHEDULER_DISPLAY_RESOURCE	"scheduler.display.resource"
public static final String	SCHEDULING_TIMEOUT_SECONDS_PER_TOPOLOGY	"scheduling.timeout.seconds.per.topology"
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_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_PLUGINS	"storm.daemon.metrics.reporter.plugins"
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_LOG4J2_CONF_DIR	"storm.log4j2.conf.dir"
public static final String	STORM_METRIC_PROCESSOR_CLASS	"storm.metricprocessor.class"
public static final String	STORM_METRIC_STORE_CLASS	"storm.metricstore.class"
public static final String	STORM_NETTY_FLUSH_CHECK_INTERVAL_MS	"storm.messaging.netty.flush.check.interval.ms"
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_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_ROCKSDB_CREATE_IF_MISSING	"storm.metricstore.rocksdb.create_if_missing"
public static final String	STORM_ROCKSDB_LOCATION	"storm.metricstore.rocksdb.location"
public static final String	STORM_ROCKSDB_METADATA_STRING_CACHE_CAPACITY	"storm.metricstore.rocksdb.metadata_string_cache_capacity"
public static final String	STORM_ROCKSDB_METRIC_DELETION_PERIOD_HOURS	"storm.metricstore.rocksdb.deletion_period_hours"
public static final String	STORM_ROCKSDB_METRIC_RETENTION_HOURS	"storm.metricstore.rocksdb.retention_hours"
public static final String	STORM_SCHEDULER	"storm.scheduler"
public static final String	STORM_TOPOLOGY_CLASSPATH_BEGINNING_ENABLED	"storm.topology.classpath.beginning.enabled"
public static final String	SUPERVISOR_AUTHORIZER	"supervisor.authorizer"
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_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_MONITOR_FREQUENCY_SECS	"supervisor.monitor.frequency.secs"
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_START_TIMEOUT_SECS	"supervisor.worker.start.timeout.secs"
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_DISABLE_HTTP_BINDING	"ui.disable.http.binding"
public static final String	UI_DISABLE_SPOUT_LAG_MONITORING	"ui.disable.spout.lag.monitoring"
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_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	VALIDATE_TOPOLOGY_SCHEDULER_STRATEGY	"topology.scheduler.strategy"
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"

org.apache.storm.ExclamationTopology

Modifier and Type	Constant Field	Value
public static final String	EXCLAIM_1	"exclaim1"
public static final String	EXCLAIM_2	"exclaim2"
public static final int	EXCLAIM_2_EXECUTORS	2
public static final int	SPOUT_EXECUTORS	10
public static final String	WORD	"word"

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	LEADERINFO_ROOT	"leader-info"
public static final String	LEADERINFO_SUBTREE	"/leader-info"
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	SECRET_KEYS_ROOT	"secretkeys"
public static final String	SECRET_KEYS_SUBTREE	"/secretkeys"
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.AbstractHadoopNimbusPluginAutoCreds

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

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_EVENT_LOGGER_ARGUMENTS	"arguments"
public static final String	TOPOLOGY_EVENT_LOGGER_CLASS	"class"
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.daemon.logviewer.LogviewerConstant

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_BYTES_PER_PAGE	51200

org.apache.storm.daemon.logviewer.handler.LogviewerLogSearchHandler

Modifier and Type	Constant Field	Value
public static final int	GREP_BUF_SIZE	2048
public static final int	GREP_CONTEXT_SIZE	128
public static final int	GREP_MAX_SEARCH_SIZE	1024

org.apache.storm.daemon.logviewer.handler.LogviewerProfileHandler

Modifier and Type	Constant Field	Value
public static final String	WORKER_LOG_FILENAME	"worker.log"

org.apache.storm.daemon.logviewer.utils.DirectoryCleaner

Modifier and Type	Constant Field	Value
public static final int	MAX_NUMBER_OF_FILES_FOR_DIR	1024

org.apache.storm.daemon.logviewer.utils.ExceptionMeterNames

Modifier and Type	Constant Field	Value
public static final String	NUM_CLEANUP_EXCEPTIONS	"logviewer:num-other-cleanup-exceptions"
public static final String	NUM_DOWNLOAD_DAEMON_LOG_EXCEPTIONS	"logviewer:num-download-daemon-log-exceptions"
public static final String	NUM_DOWNLOAD_DUMP_EXCEPTIONS	"logviewer:num-download-dump-exceptions"
public static final String	NUM_DOWNLOAD_LOG_EXCEPTIONS	"logviewer:num-download-log-exceptions"
public static final String	NUM_FILE_DOWNLOAD_EXCEPTIONS	"logviewer:num-file-download-exceptions"
public static final String	NUM_FILE_OPEN_EXCEPTIONS	"logviewer:num-file-open-exceptions"
public static final String	NUM_FILE_READ_EXCEPTIONS	"logviewer:num-file-read-exceptions"
public static final String	NUM_FILE_REMOVAL_EXCEPTIONS	"logviewer:num-file-removal-exceptions"
public static final String	NUM_LIST_DUMP_EXCEPTIONS	"logviewer:num-list-dump-files-exceptions"
public static final String	NUM_LIST_LOG_EXCEPTIONS	"logviewer:num-search-log-exceptions"
public static final String	NUM_READ_DAEMON_LOG_EXCEPTIONS	"logviewer:num-read-daemon-log-exceptions"
public static final String	NUM_READ_LOG_EXCEPTIONS	"logviewer:num-read-log-exceptions"
public static final String	NUM_SEARCH_EXCEPTIONS	"logviewer:num-search-exceptions"
public static final String	NUM_SET_PERMISSION_EXCEPTIONS	"logviewer:num-set-permission-exceptions"

org.apache.storm.daemon.logviewer.utils.WorkerLogs

Modifier and Type	Constant Field	Value
public static final String	WORKER_YAML	"worker.yaml"

org.apache.storm.daemon.ui.UIServer

Modifier and Type	Constant Field	Value
public static final String	STORM_API_URL_PREFIX	"/api/v1/"

org.apache.storm.daemon.ui.resources.StormApiResource

Modifier and Type	Constant Field	Value
public static final String	callbackParameterName	"callback"

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.elasticsearch.common.EsConstants

Modifier and Type	Constant Field	Value
public static final String	CLUSTER_NAME	"test-cluster"
public static final int	WAIT_DEFAULT_SECS	5

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	DefaultStartingOffset	"-1"
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"
public static final String	SYSTEM_META_DATA	"eventdata_system_properties"

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.HBaseSecurityUtil

Modifier and Type	Constant Field	Value
public static final String	HBASE_CREDENTIALS	"HBASE_CREDENTIALS"
public static final String	HBASE_CREDENTIALS_CONFIG_KEYS	"hbaseCredentialsConfigKeys"
public static final String	HBASE_KEYTAB_FILE_KEY	"hbase.keytab.file"
public static final String	HBASE_PRINCIPAL_KEY	"hbase.kerberos.principal"
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.HdfsSecurityUtil

Modifier and Type	Constant Field	Value
public static final String	HDFS_CREDENTIALS	"HDFS_CREDENTIALS"
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"
public static final String	TOPOLOGY_HDFS_URI	"topology.hdfs.uri"

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<KeyT extends org.apache.hadoop.io.Writable,ValueT 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.HiveSecurityUtil

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

org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopics

Modifier and Type	Constant Field	Value
public static final String	TOPIC_0	"kafka-spout-test"
public static final String	TOPIC_1	"kafka-spout-test-1"
public static final String	TOPIC_2	"kafka-spout-test-2"

org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig<K,V>

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_PARTITION_REFRESH_PERIOD_MS	2000L
public static final long	DEFAULT_POLL_TIMEOUT_MS	200L
public static final long	DEFAULT_START_TS	0L

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	TOPOLOGY_ID_KEY	"topologyId"

org.apache.storm.kafka.spout.trident.KafkaTridentSpoutCoordinator<K,V>

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

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.loadgen.CaptureLoad

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_OUT_DIR	"./loadgen/"

org.apache.storm.loadgen.LoadMetricsServer

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_REPORT_INTERVAL	30L
public static final long	DEFAULT_WINDOW_INTERVAL	30L

org.apache.storm.localizer.LocallyCachedBlob

Modifier and Type	Constant Field	Value
public static final long	NOT_DOWNLOADED_VERSION	-1L

org.apache.storm.localizer.LocallyCachedTopologyBlob

Modifier and Type	Constant Field	Value
public static final long	LOCAL_MODE_JAR_VERSION	1L

org.apache.storm.messaging.netty.BackPressureStatus

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

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.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.KafkaClientHdfsTopo

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_BOOTSTRAP_HOSTS	"kafka.bootstrap.hosts"
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"

org.apache.storm.perf.KafkaClientSpoutNullBoltTopo

Modifier and Type	Constant Field	Value
public static final String	BOLT_ID	"devNullBolt"
public static final String	BOLT_NUM	"bolt.count"
public static final String	BOOTSTRAP_SERVERS	"bootstrap.servers"
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	OFFSET_COMMIT_PERIOD_MS	"offset.commit.period.ms"
public static final String	PROCESSING_GUARANTEE	"processing.guarantee"
public static final String	SPOUT_ID	"kafkaSpout"
public static final String	SPOUT_NUM	"spout.count"

org.apache.storm.perf.SimplifiedWordCountTopo

Modifier and Type	Constant Field	Value
public static final String	BOLT_NUM	"counter.count"
public static final String	COUNT_ID	"counter"
public static final int	DEFAULT_COUNT_BOLT_NUM	1
public static final int	DEFAULT_SPOUT_NUM	1
public static final String	INPUT_FILE	"input.file"
public static final String	SPOUT_ID	"spout"
public static final String	SPOUT_NUM	"spout.count"
public static final String	TOPOLOGY_NAME	"SimplifiedWordCountTopo"

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

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

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	"%.3f"
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	"%.3f"
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.rocketmq.RocketMqConfig

Modifier and Type	Constant Field	Value
public static final String	BROKER_HEART_BEAT_INTERVAL	"brokerserver.heartbeat.interval"
public static final String	CONSUMER_BATCH_PROCESS_TIMEOUT	"consumer.batch.process.timeout"
public static final String	CONSUMER_BATCH_SIZE	"consumer.batch.size"
public static final String	CONSUMER_CALLBACK_EXECUTOR_THREADS	"consumer.callback.executor.threads"
public static final String	CONSUMER_GROUP	"consumer.group"
public static final String	CONSUMER_MAX_THREADS	"consumer.max.threads"
public static final String	CONSUMER_MESSAGES_ORDERLY	"consumer.messages.orderly"
public static final String	CONSUMER_MIN_THREADS	"consumer.min.threads"
public static final String	CONSUMER_OFFSET_EARLIEST	"earliest"
public static final String	CONSUMER_OFFSET_FROM_TIMESTAMP	"consumer.offset.from.timestamp"
public static final String	CONSUMER_OFFSET_LATEST	"latest"
public static final String	CONSUMER_OFFSET_PERSIST_INTERVAL	"consumer.offset.persist.interval"
public static final String	CONSUMER_OFFSET_RESET_TO	"consumer.offset.reset.to"
public static final String	CONSUMER_OFFSET_TIMESTAMP	"timestamp"
public static final String	CONSUMER_TAG	"consumer.tag"
public static final String	CONSUMER_TOPIC	"consumer.topic"
public static final int	DEFAULT_BROKER_HEART_BEAT_INTERVAL	30000
public static final int	DEFAULT_CONSUMER_BATCH_SIZE	32
public static final int	DEFAULT_CONSUMER_MAX_THREADS	64
public static final int	DEFAULT_CONSUMER_MIN_THREADS	20
public static final int	DEFAULT_CONSUMER_OFFSET_PERSIST_INTERVAL	5000
public static final String	DEFAULT_CONSUMER_TAG	"*"
public static final int	DEFAULT_NAME_SERVER_POLL_INTERVAL	30000
public static final int	DEFAULT_PRODUCER_RETRY_TIMES	3
public static final int	DEFAULT_PRODUCER_TIMEOUT	3000
public static final String	NAME_SERVER_ADDR	"nameserver.address"
public static final String	NAME_SERVER_POLL_INTERVAL	"nameserver.poll.interval"
public static final String	PRODUCER_GROUP	"producer.group"
public static final String	PRODUCER_RETRY_TIMES	"producer.retry.times"
public static final String	PRODUCER_TIMEOUT	"producer.timeout"

org.apache.storm.rocketmq.SpoutConfig

Modifier and Type	Constant Field	Value
public static final String	SCHEME	"spout.scheme"

org.apache.storm.rocketmq.common.mapper.FieldNameBasedTupleToMessageMapper

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

org.apache.storm.rocketmq.spout.scheme.StringScheme

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

org.apache.storm.scheduler.blacklist.BlacklistScheduler

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_BLACKLIST_SCHEDULER_RESUME_TIME	1800
public static final int	DEFAULT_BLACKLIST_SCHEDULER_TOLERANCE_COUNT	3
public static final int	DEFAULT_BLACKLIST_SCHEDULER_TOLERANCE_TIME	300

org.apache.storm.scheduler.blacklist.strategies.DefaultBlacklistStrategy

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_BLACKLIST_SCHEDULER_RESUME_TIME	1800
public static final int	DEFAULT_BLACKLIST_SCHEDULER_TOLERANCE_COUNT	3

org.apache.storm.scheduler.utils.ArtifactoryConfigLoader

Modifier and Type	Constant Field	Value
protected static final String	LOCAL_ARTIFACT_DIR	"scheduler_artifacts"

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.ClientAuthUtils

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.FixedGroupsMapping

Modifier and Type	Constant Field	Value
public static final String	STORM_FIXED_GROUP_MAPPING	"storm.fixed.group.mapping"

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.JassPasswordProvider

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.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.mongodb.MongoDataSourcesProvider

Modifier and Type	Constant Field	Value
public static final String	COLLECTION_NAME	"collection.name"
public static final String	DEFAULT_VALUE_SERIALIZED_FIELD	"tridentSerField"
public static final String	SCHEME_NAME	"mongodb"
public static final String	TRIDENT_VALUE_SERIALIZED_FIELD	"trident.ser.field"
public static final String	VALUE_SERIALIZED_FIELD	"ser.field"

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

org.apache.storm.sql.planner.streams.QueryPlanner

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

org.apache.storm.sql.planner.streams.rules.StreamsScanRule

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

org.apache.storm.st.topology.TestableTopology

Modifier and Type	Constant Field	Value
public static final String	DUMMY_FIELD	"dummy"
public static final int	TIMEDATA_SLEEP_BETWEEN_EMITS_MS	20

org.apache.storm.st.topology.window.IncrementingSpout

Modifier and Type	Constant Field	Value
public static final String	NUMBER_FIELD	"number"

org.apache.storm.stats.ClientStatsUtil

Modifier and Type	Constant Field	Value
public static final String	BOLT	"bolt"
public static final String	SPOUT	"spout"
public static final String	TIME_SECS	"time-secs"

org.apache.storm.stats.StatsUtil

Modifier and Type	Constant Field	Value
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.streams.WindowNode

Modifier and Type	Constant Field	Value
public static final String	PUNCTUATION	"__punctuation"

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	RESOURCES_SUBDIR	"resources"
public static final String	STORM_HOME	"storm.home"

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.ServerConfigUtils

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.ServerUtils

Modifier and Type	Constant Field	Value
public static final int	SIGKILL	9
public static final int	SIGTERM	15

org.apache.storm.utils.Utils

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

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

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

org.apache.storm.windowing.persistence.WindowState<T>

Modifier and Type	Constant Field	Value
public static final int	MAX_PARTITION_EVENTS	1000
public static final int	MIN_PARTITIONS	10