Constant Field Values
Contents
org.apache.*
-
org.apache.storm.Config Modifier and Type Constant Field Value public static final StringBLOBSTORE_CLEANUP_ENABLE"blobstore.cleanup.enable"public static final StringBLOBSTORE_DIR"blobstore.dir"public static final StringBLOBSTORE_HDFS_KEYTAB"blobstore.hdfs.keytab"public static final StringBLOBSTORE_HDFS_PRINCIPAL"blobstore.hdfs.principal"public static final StringCLIENT_BLOBSTORE"client.blobstore.class"public static final StringDISABLE_SYMLINKS"storm.disable.symlinks"public static final StringDRPC_AUTHORIZER_ACL"drpc.authorizer.acl"public static final StringDRPC_AUTHORIZER_ACL_FILENAME"drpc.authorizer.acl.filename"public static final StringDRPC_AUTHORIZER_ACL_STRICT"drpc.authorizer.acl.strict"public static final StringDRPC_INVOCATIONS_PORT"drpc.invocations.port"public static final StringDRPC_INVOCATIONS_THREADS"drpc.invocations.threads"public static final StringDRPC_INVOCATIONS_THRIFT_TRANSPORT_PLUGIN"drpc.invocations.thrift.transport"public static final StringDRPC_MAX_BUFFER_SIZE"drpc.max_buffer_size"public static final StringDRPC_PORT"drpc.port"public static final StringDRPC_QUEUE_SIZE"drpc.queue.size"public static final StringDRPC_SERVERS"drpc.servers"public static final StringDRPC_THRIFT_TRANSPORT_PLUGIN"drpc.thrift.transport"public static final StringDRPC_WORKER_THREADS"drpc.worker.threads"public static final StringEXECUTOR_METRICS_FREQUENCY_SECS"executor.metrics.frequency.secs"public static final StringNIMBUS_ADMINS"nimbus.admins"public static final StringNIMBUS_ADMINS_GROUPS"nimbus.admins.groups"public static final StringNIMBUS_AUTO_CRED_PLUGINS"nimbus.autocredential.plugins.classes"public static final StringNIMBUS_CREDENTIAL_RENEWERS"nimbus.credential.renewers.classes"public static final StringNIMBUS_DAEMON_USERS"nimbus.daemon.users"public static final StringNIMBUS_GROUPS"nimbus.groups"public static final StringNIMBUS_IMPERSONATION_ACL"nimbus.impersonation.acl"public static final StringNIMBUS_LOCAL_ASSIGNMENTS_BACKEND_CLASS"nimbus.local.assignments.backend.class"public static final StringNIMBUS_QUEUE_SIZE"nimbus.queue.size"public static final StringNIMBUS_SCHEDULER_STRATEGY_CLASS_WHITELIST"nimbus.scheduler.strategy.class.whitelist"public static final StringNIMBUS_SEEDS"nimbus.seeds"public static final StringNIMBUS_SUPERVISOR_USERS"nimbus.supervisor.users"public static final StringNIMBUS_THRIFT_CLIENT_USE_TLS"nimbus.thrift.client.use.tls"public static final StringNIMBUS_THRIFT_MAX_BUFFER_SIZE"nimbus.thrift.max_buffer_size"public static final StringNIMBUS_THRIFT_PORT"nimbus.thrift.port"public static final StringNIMBUS_THRIFT_THREADS"nimbus.thrift.threads"public static final StringNIMBUS_THRIFT_TLS_CLIENT_AUTH_REQUIRED"nimbus.thrift.tls.client.auth.required"public static final StringNIMBUS_THRIFT_TLS_CLIENT_CERT_PATH"nimbus.thrift.tls.client.cert.path"public static final StringNIMBUS_THRIFT_TLS_CLIENT_KEY_PATH"nimbus.thrift.tls.client.key.path"public static final StringNIMBUS_THRIFT_TLS_CLIENT_KEYSTORE_PASSWORD"nimbus.thrift.tls.client.keystore.password"public static final StringNIMBUS_THRIFT_TLS_CLIENT_KEYSTORE_PATH"nimbus.thrift.tls.client.keystore.path"public static final StringNIMBUS_THRIFT_TLS_CLIENT_TRUSTSTORE_PASSWORD"nimbus.thrift.tls.client.truststore.password"public static final StringNIMBUS_THRIFT_TLS_CLIENT_TRUSTSTORE_PATH"nimbus.thrift.tls.client.truststore.path"public static final StringNIMBUS_THRIFT_TLS_MAX_BUFFER_SIZE"nimbus.thrift.tls.max_buffer_size"public static final StringNIMBUS_THRIFT_TLS_PORT"nimbus.thrift.tls.port"public static final StringNIMBUS_THRIFT_TLS_SERVER_KEYSTORE_PASSWORD"nimbus.thrift.tls.server.keystore.password"public static final StringNIMBUS_THRIFT_TLS_SERVER_KEYSTORE_PATH"nimbus.thrift.tls.server.keystore.path"public static final StringNIMBUS_THRIFT_TLS_SERVER_ONLY"nimbus.thrift.tls.server.only"public static final StringNIMBUS_THRIFT_TLS_SERVER_TRUSTSTORE_PASSWORD"nimbus.thrift.tls.server.truststore.password"public static final StringNIMBUS_THRIFT_TLS_SERVER_TRUSTSTORE_PATH"nimbus.thrift.tls.server.truststore.path"public static final StringNIMBUS_THRIFT_TLS_THREADS"nimbus.thrift.tls.threads"public static final StringNIMBUS_THRIFT_TLS_TRANSPORT_PLUGIN"nimbus.thrift.tls.transport"public static final StringNIMBUS_THRIFT_TRANSPORT_PLUGIN"nimbus.thrift.transport"public static final StringNIMBUS_USERS"nimbus.users"public static final StringNUM_STAT_BUCKETS"num.stat.buckets"public static final StringPACEMAKER_AUTH_METHOD"pacemaker.auth.method"public static final StringPACEMAKER_CLIENT_MAX_THREADS"pacemaker.client.max.threads"public static final StringPACEMAKER_PORT"pacemaker.port"public static final StringPACEMAKER_SERVERS"pacemaker.servers"public static final StringPACEMAKER_THRIFT_MESSAGE_SIZE_MAX"pacemaker.thrift.message.size.max"public static final StringSTORM_BLOBSTORE_ACL_VALIDATION_ENABLED"storm.blobstore.acl.validation.enabled"public static final StringSTORM_BLOBSTORE_DEPENDENCY_JAR_UPLOAD_CHUNK_SIZE_BYTES"storm.blobstore.dependency.jar.upload.chunk.size.bytes"public static final StringSTORM_BLOBSTORE_INPUTSTREAM_BUFFER_SIZE_BYTES"storm.blobstore.inputstream.buffer.size.bytes"public static final StringSTORM_BLOBSTORE_REPLICATION_FACTOR"storm.blobstore.replication.factor"public static final StringSTORM_CGROUP_HIERARCHY_DIR"storm.cgroup.hierarchy.dir"public static final StringSTORM_CLUSTER_MODE"storm.cluster.mode"public static final StringSTORM_CLUSTER_STATE_STORE"storm.cluster.state.store"public static final StringSTORM_DAEMON_METRICS_REPORTER_PLUGIN_DURATION_UNIT"storm.daemon.metrics.reporter.plugin.duration.unit"public static final StringSTORM_DAEMON_METRICS_REPORTER_PLUGIN_LOCALE"storm.daemon.metrics.reporter.plugin.locale"public static final StringSTORM_DAEMON_METRICS_REPORTER_PLUGIN_RATE_UNIT"storm.daemon.metrics.reporter.plugin.rate.unit"public static final StringSTORM_DO_AS_USER"storm.doAsUser"public static final StringSTORM_GROUP_MAPPING_SERVICE_CACHE_DURATION_SECS"storm.group.mapping.service.cache.duration.secs"public static final StringSTORM_GROUP_MAPPING_SERVICE_PARAMS"storm.group.mapping.service.params"public static final StringSTORM_GROUP_MAPPING_SERVICE_PROVIDER_PLUGIN"storm.group.mapping.service"public static final StringSTORM_HDFS_LOGIN_KEYTAB"storm.hdfs.login.keytab"public static final StringSTORM_HDFS_LOGIN_PRINCIPAL"storm.hdfs.login.principal"public static final StringSTORM_ID"storm.id"public static final StringSTORM_LOCAL_DIR"storm.local.dir"public static final StringSTORM_LOCAL_HOSTNAME"storm.local.hostname"public static final StringSTORM_LOCAL_MODE_ZMQ"storm.local.mode.zmq"public static final StringSTORM_MESSAGING_NETTY_AUTHENTICATION"storm.messaging.netty.authentication"public static final StringSTORM_MESSAGING_NETTY_BUFFER_HIGH_WATERMARK"storm.messaging.netty.buffer.high.watermark"public static final StringSTORM_MESSAGING_NETTY_BUFFER_LOW_WATERMARK"storm.messaging.netty.buffer.low.watermark"public static final StringSTORM_MESSAGING_NETTY_BUFFER_SIZE"storm.messaging.netty.buffer_size"public static final StringSTORM_MESSAGING_NETTY_CLIENT_WORKER_THREADS"storm.messaging.netty.client_worker_threads"public static final StringSTORM_MESSAGING_NETTY_FLUSH_TIMEOUT_MS"storm.messaging.netty.flush_timeout_ms"public static final StringSTORM_MESSAGING_NETTY_MAX_SLEEP_MS"storm.messaging.netty.max_wait_ms"public static final StringSTORM_MESSAGING_NETTY_MIN_SLEEP_MS"storm.messaging.netty.min_wait_ms"public static final StringSTORM_MESSAGING_NETTY_SERVER_WORKER_THREADS"storm.messaging.netty.server_worker_threads"public static final StringSTORM_MESSAGING_NETTY_SOCKET_BACKLOG"storm.messaging.netty.socket.backlog"public static final StringSTORM_MESSAGING_NETTY_TLS_CIPHERS"storm.messaging.netty.tls.ciphers"public static final StringSTORM_MESSAGING_NETTY_TLS_CLIENT_KEYSTORE_PASSWORD"storm.messaging.netty.tls.client.keystore.password"public static final StringSTORM_MESSAGING_NETTY_TLS_CLIENT_KEYSTORE_PATH"storm.messaging.netty.tls.client.keystore.path"public static final StringSTORM_MESSAGING_NETTY_TLS_CLIENT_TRUSTSTORE_PASSWORD"storm.messaging.netty.tls.client.truststore.password"public static final StringSTORM_MESSAGING_NETTY_TLS_CLIENT_TRUSTSTORE_PATH"storm.messaging.netty.tls.client.truststore.path"public static final StringSTORM_MESSAGING_NETTY_TLS_ENABLE"storm.messaging.netty.tls.enable"public static final StringSTORM_MESSAGING_NETTY_TLS_KEYSTORE_PASSWORD"storm.messaging.netty.tls.keystore.password"public static final StringSTORM_MESSAGING_NETTY_TLS_KEYSTORE_PATH"storm.messaging.netty.tls.keystore.path"public static final StringSTORM_MESSAGING_NETTY_TLS_REQUIRE_OPEN_SSL"storm.messaging.netty.tls.require.open.ssl"public static final StringSTORM_MESSAGING_NETTY_TLS_SSL_PROTOCOLS"storm.messaging.netty.tls.ssl.protocols"public static final StringSTORM_MESSAGING_NETTY_TLS_TRUSTSTORE_PASSWORD"storm.messaging.netty.tls.truststore.password"public static final StringSTORM_MESSAGING_NETTY_TLS_TRUSTSTORE_PATH"storm.messaging.netty.tls.truststore.path"public static final StringSTORM_MESSAGING_TRANSPORT"storm.messaging.transport"public static final StringSTORM_META_SERIALIZATION_DELEGATE"storm.meta.serialization.delegate"public static final StringSTORM_METRICS_REPORTERS"storm.metrics.reporters"public static final StringSTORM_NETTY_MESSAGE_BATCH_SIZE"storm.messaging.netty.transfer.batch.size"public static final StringSTORM_NETWORK_TOPOGRAPHY_PLUGIN"storm.network.topography.plugin"public static final StringSTORM_NIMBUS_RETRY_INTERVAL"storm.nimbus.retry.interval.millis"public static final StringSTORM_NIMBUS_RETRY_INTERVAL_CEILING"storm.nimbus.retry.intervalceiling.millis"public static final StringSTORM_NIMBUS_RETRY_TIMES"storm.nimbus.retry.times"public static final StringSTORM_PRINCIPAL_TO_LOCAL_PLUGIN"storm.principal.tolocal"public static final StringSTORM_THRIFT_SOCKET_TIMEOUT_MS"storm.thrift.socket.timeout.ms"public static final StringSTORM_THRIFT_TLS_SOCKET_TIMEOUT_MS"storm.thrift.tls.socket.timeout.ms"public static final StringSTORM_THRIFT_TRANSPORT_PLUGIN"storm.thrift.transport"public static final StringSTORM_TOPOLOGY_METRICS_SYSTEM_REPORTERS"storm.topology.metrics.system.reporters"public static final StringSTORM_TOPOLOGY_SUBMISSION_NOTIFIER_PLUGIN"storm.topology.submission.notifier.plugin.class"public static final StringSTORM_WORKERS_ARTIFACTS_DIR"storm.workers.artifacts.dir"public static final StringSTORM_ZOOKEEPER_AUTH_PAYLOAD"storm.zookeeper.auth.payload"public static final StringSTORM_ZOOKEEPER_AUTH_SCHEME"storm.zookeeper.auth.scheme"public static final StringSTORM_ZOOKEEPER_CONNECTION_TIMEOUT"storm.zookeeper.connection.timeout"public static final StringSTORM_ZOOKEEPER_DRPC_ACL"storm.zookeeper.drpcACL"public static final StringSTORM_ZOOKEEPER_PORT"storm.zookeeper.port"public static final StringSTORM_ZOOKEEPER_RETRY_INTERVAL"storm.zookeeper.retry.interval"public static final StringSTORM_ZOOKEEPER_RETRY_INTERVAL_CEILING"storm.zookeeper.retry.intervalceiling.millis"public static final StringSTORM_ZOOKEEPER_RETRY_TIMES"storm.zookeeper.retry.times"public static final StringSTORM_ZOOKEEPER_ROOT"storm.zookeeper.root"public static final StringSTORM_ZOOKEEPER_SERVERS"storm.zookeeper.servers"public static final StringSTORM_ZOOKEEPER_SESSION_TIMEOUT"storm.zookeeper.session.timeout"public static final StringSTORM_ZOOKEEPER_SSL_HOSTNAME_VERIFICATION"storm.zookeeper.ssl.hostnameVerification"public static final StringSTORM_ZOOKEEPER_SSL_KEYSTORE_PASSWORD"storm.zookeeper.ssl.keystore.password"public static final StringSTORM_ZOOKEEPER_SSL_KEYSTORE_PATH"storm.zookeeper.ssl.keystore.path"public static final StringSTORM_ZOOKEEPER_SSL_TRUSTSTORE_PASSWORD"storm.zookeeper.ssl.truststore.password"public static final StringSTORM_ZOOKEEPER_SSL_TRUSTSTORE_PATH"storm.zookeeper.ssl.truststore.path"public static final StringSTORM_ZOOKEEPER_SUPERACL"storm.zookeeper.superACL"public static final StringSTORM_ZOOKEEPER_TOPOLOGY_AUTH_PAYLOAD"storm.zookeeper.topology.auth.payload"public static final StringSTORM_ZOOKEEPER_TOPOLOGY_AUTH_SCHEME"storm.zookeeper.topology.auth.scheme"public static final StringSUPERVISOR_CPU_CAPACITY"supervisor.cpu.capacity"public static final StringSUPERVISOR_MEMORY_CAPACITY_MB"supervisor.memory.capacity.mb"public static final StringSUPERVISOR_QUEUE_SIZE"supervisor.queue.size"public static final StringSUPERVISOR_RESOURCES_MAP"supervisor.resources.map"public static final StringSUPERVISOR_RUN_WORKER_AS_USER"supervisor.run.worker.as.user"public static final StringSUPERVISOR_THRIFT_CLIENT_USE_TLS"supervisor.thrift.client.use.tls"public static final StringSUPERVISOR_THRIFT_MAX_BUFFER_SIZE"supervisor.thrift.max_buffer_size"public static final StringSUPERVISOR_THRIFT_PORT"supervisor.thrift.port"public static final StringSUPERVISOR_THRIFT_SOCKET_TIMEOUT_MS"supervisor.thrift.socket.timeout.ms"public static final StringSUPERVISOR_THRIFT_THREADS"supervisor.thrift.threads"public static final StringSUPERVISOR_THRIFT_TLS_CLIENT_AUTH_REQUIRED"supervisor.thrift.tls.client.auth.required"public static final StringSUPERVISOR_THRIFT_TLS_CLIENT_CERT_PATH"supervisor.thrift.tls.client.cert.path"public static final StringSUPERVISOR_THRIFT_TLS_CLIENT_KEY_PATH"supervisor.thrift.tls.client.key.path"public static final StringSUPERVISOR_THRIFT_TLS_CLIENT_KEYSTORE_PASSWORD"supervisor.thrift.tls.client.keystore.password"public static final StringSUPERVISOR_THRIFT_TLS_CLIENT_KEYSTORE_PATH"supervisor.thrift.tls.client.keystore.path"public static final StringSUPERVISOR_THRIFT_TLS_CLIENT_TRUSTSTORE_PASSWORD"supervisor.thrift.tls.client.truststore.password"public static final StringSUPERVISOR_THRIFT_TLS_CLIENT_TRUSTSTORE_PATH"supervisor.thrift.tls.client.truststore.path"public static final StringSUPERVISOR_THRIFT_TLS_SERVER_KEYSTORE_PASSWORD"supervisor.thrift.tls.server.keystore.password"public static final StringSUPERVISOR_THRIFT_TLS_SERVER_KEYSTORE_PATH"supervisor.thrift.tls.server.keystore.path"public static final StringSUPERVISOR_THRIFT_TLS_SERVER_TRUSTSTORE_PASSWORD"supervisor.thrift.tls.server.truststore.password"public static final StringSUPERVISOR_THRIFT_TLS_SERVER_TRUSTSTORE_PATH"supervisor.thrift.tls.server.truststore.path"public static final StringSUPERVISOR_THRIFT_TRANSPORT_PLUGIN"supervisor.thrift.transport"public static final StringSUPERVISOR_WORKER_DEFAULT_VERSION"supervisor.worker.default.version"public static final StringSUPERVISOR_WORKER_HEARTBEATS_MAX_TIMEOUT_SECS"supervisor.worker.heartbeats.max.timeout.secs"public static final StringSUPERVISOR_WORKER_LAUNCHER"supervisor.worker.launcher"public static final StringSUPERVISOR_WORKER_SHUTDOWN_SLEEP_SECS"supervisor.worker.shutdown.sleep.secs"public static final StringSUPERVISOR_WORKER_TIMEOUT_SECS"supervisor.worker.timeout.secs"public static final StringSUPERVISOR_WORKER_VERSION_CLASSPATH_MAP"supervisor.worker.version.classpath.map"public static final StringSUPERVISOR_WORKER_VERSION_LOGWRITER_MAP"supervisor.worker.version.logwriter.map"public static final StringSUPERVISOR_WORKER_VERSION_MAIN_MAP"supervisor.worker.version.main.map"public static final StringTASK_CREDENTIALS_POLL_SECS"task.credentials.poll.secs"public static final StringTASK_HEARTBEAT_FREQUENCY_SECS"task.heartbeat.frequency.secs"public static final StringTASK_REFRESH_POLL_SECS"task.refresh.poll.secs"public static final StringTOPOLOGY_ACKER_CPU_PCORE_PERCENT"topology.acker.cpu.pcore.percent"public static final StringTOPOLOGY_ACKER_EXECUTORS"topology.acker.executors"public static final StringTOPOLOGY_ACKER_RESOURCES_OFFHEAP_MEMORY_MB"topology.acker.resources.offheap.memory.mb"public static final StringTOPOLOGY_ACKER_RESOURCES_ONHEAP_MEMORY_MB"topology.acker.resources.onheap.memory.mb"public static final StringTOPOLOGY_AUTO_CREDENTIALS"topology.auto-credentials"public static final StringTOPOLOGY_AUTO_TASK_HOOKS"topology.auto.task.hooks"public static final StringTOPOLOGY_BACKPRESSURE_CHECK_MILLIS"topology.backpressure.check.millis"public static final StringTOPOLOGY_BACKPRESSURE_ENABLE"topology.backpressure.enable"public static final StringTOPOLOGY_BACKPRESSURE_WAIT_PARK_MICROSEC"topology.backpressure.wait.park.microsec"public static final StringTOPOLOGY_BACKPRESSURE_WAIT_PROGRESSIVE_LEVEL1_COUNT"topology.backpressure.wait.progressive.level1.count"public static final StringTOPOLOGY_BACKPRESSURE_WAIT_PROGRESSIVE_LEVEL2_COUNT"topology.backpressure.wait.progressive.level2.count"public static final StringTOPOLOGY_BACKPRESSURE_WAIT_PROGRESSIVE_LEVEL3_SLEEP_MILLIS"topology.backpressure.wait.progressive.level3.sleep.millis"public static final StringTOPOLOGY_BACKPRESSURE_WAIT_STRATEGY"topology.backpressure.wait.strategy"public static final StringTOPOLOGY_BATCH_FLUSH_INTERVAL_MILLIS"topology.batch.flush.interval.millis"public static final StringTOPOLOGY_BLOBSTORE_MAP"topology.blobstore.map"public static final StringTOPOLOGY_BOLT_WAIT_PARK_MICROSEC"topology.bolt.wait.park.microsec"public static final StringTOPOLOGY_BOLT_WAIT_PROGRESSIVE_LEVEL1_COUNT"topology.bolt.wait.progressive.level1.count"public static final StringTOPOLOGY_BOLT_WAIT_PROGRESSIVE_LEVEL2_COUNT"topology.bolt.wait.progressive.level2.count"public static final StringTOPOLOGY_BOLT_WAIT_PROGRESSIVE_LEVEL3_SLEEP_MILLIS"topology.bolt.wait.progressive.level3.sleep.millis"public static final StringTOPOLOGY_BOLT_WAIT_STRATEGY"topology.bolt.wait.strategy"public static final StringTOPOLOGY_BOLTS_LATE_TUPLE_STREAM"topology.bolts.late.tuple.stream"public static final StringTOPOLOGY_BOLTS_MESSAGE_ID_FIELD_NAME"topology.bolts.message.id.field.name"public static final StringTOPOLOGY_BOLTS_SLIDING_INTERVAL_COUNT"topology.bolts.window.sliding.interval.count"public static final StringTOPOLOGY_BOLTS_SLIDING_INTERVAL_DURATION_MS"topology.bolts.window.sliding.interval.duration.ms"public static final StringTOPOLOGY_BOLTS_TUPLE_TIMESTAMP_MAX_LAG_MS"topology.bolts.tuple.timestamp.max.lag.ms"public static final StringTOPOLOGY_BOLTS_WATERMARK_EVENT_INTERVAL_MS"topology.bolts.watermark.event.interval.ms"public static final StringTOPOLOGY_BOLTS_WINDOW_LENGTH_COUNT"topology.bolts.window.length.count"public static final StringTOPOLOGY_BOLTS_WINDOW_LENGTH_DURATION_MS"topology.bolts.window.length.duration.ms"public static final StringTOPOLOGY_BUILTIN_METRICS_BUCKET_SIZE_SECS"topology.builtin.metrics.bucket.size.secs"public static final StringTOPOLOGY_CLASSPATH"topology.classpath"public static final StringTOPOLOGY_CLASSPATH_BEGINNING"topology.classpath.beginning"public static final StringTOPOLOGY_COMPONENT_CPU_PCORE_PERCENT"topology.component.cpu.pcore.percent"public static final StringTOPOLOGY_COMPONENT_RESOURCES_MAP"topology.component.resources.map"public static final StringTOPOLOGY_COMPONENT_RESOURCES_OFFHEAP_MEMORY_MB"topology.component.resources.offheap.memory.mb"public static final StringTOPOLOGY_COMPONENT_RESOURCES_ONHEAP_MEMORY_MB"topology.component.resources.onheap.memory.mb"public static final StringTOPOLOGY_DEBUG"topology.debug"public static final StringTOPOLOGY_DISABLE_LOADAWARE_MESSAGING"topology.disable.loadaware.messaging"public static final StringTOPOLOGY_ENABLE_MESSAGE_TIMEOUTS"topology.enable.message.timeouts"public static final StringTOPOLOGY_ENABLE_SEND_ICONNECTION_METRICS"topology.enable.send.iconnection.metrics"public static final StringTOPOLOGY_ENABLE_V2_METRICS_TICK"topology.enable.v2.metrics.tick"public static final StringTOPOLOGY_ENVIRONMENT"topology.environment"public static final StringTOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS"topology.error.throttle.interval.secs"public static final StringTOPOLOGY_EVENT_LOGGER_REGISTER"topology.event.logger.register"public static final StringTOPOLOGY_EVENTLOGGER_EXECUTORS"topology.eventlogger.executors"public static final StringTOPOLOGY_EXECUTOR_OVERFLOW_LIMIT"topology.executor.overflow.limit"public static final StringTOPOLOGY_EXECUTOR_RECEIVE_BUFFER_SIZE"topology.executor.receive.buffer.size"public static final StringTOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION"topology.fall.back.on.java.serialization"public static final StringTOPOLOGY_GROUPS"topology.groups"public static final StringTOPOLOGY_ISOLATED_MACHINES"topology.isolate.machines"public static final StringTOPOLOGY_KRYO_DECORATORS"topology.kryo.decorators"public static final StringTOPOLOGY_KRYO_FACTORY"topology.kryo.factory"public static final StringTOPOLOGY_KRYO_REGISTER"topology.kryo.register"public static final StringTOPOLOGY_LOCALITYAWARE_HIGHER_BOUND"topology.localityaware.higher.bound"public static final StringTOPOLOGY_LOCALITYAWARE_LOWER_BOUND"topology.localityaware.lower.bound"public static final StringTOPOLOGY_LOGGING_CONFIG_FILE"topology.logging.config"public static final StringTOPOLOGY_LOGGING_SENSITIVITY"topology.logging.sensitivity"public static final StringTOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL"topology.max.error.report.per.interval"public static final StringTOPOLOGY_MAX_REPLICATION_WAIT_TIME_SEC"topology.max.replication.wait.time.sec"public static final StringTOPOLOGY_MAX_SPOUT_PENDING"topology.max.spout.pending"public static final StringTOPOLOGY_MAX_TASK_PARALLELISM"topology.max.task.parallelism"public static final StringTOPOLOGY_MESSAGE_TIMEOUT_SECS"topology.message.timeout.secs"public static final StringTOPOLOGY_METRICS_CONSUMER_CPU_PCORE_PERCENT"topology.metrics.consumer.cpu.pcore.percent"public static final StringTOPOLOGY_METRICS_CONSUMER_REGISTER"topology.metrics.consumer.register"public static final StringTOPOLOGY_METRICS_CONSUMER_RESOURCES_OFFHEAP_MEMORY_MB"topology.metrics.consumer.resources.offheap.memory.mb"public static final StringTOPOLOGY_METRICS_CONSUMER_RESOURCES_ONHEAP_MEMORY_MB"topology.metrics.consumer.resources.onheap.memory.mb"public static final StringTOPOLOGY_METRICS_REPORTERS"topology.metrics.reporters"public static final StringTOPOLOGY_MIN_REPLICATION_COUNT"topology.min.replication.count"public static final StringTOPOLOGY_MULTILANG_LOG_HANDLER"topology.multilang.log.handler"public static final StringTOPOLOGY_MULTILANG_SERIALIZER"topology.multilang.serializer"public static final StringTOPOLOGY_NAME"topology.name"public static final StringTOPOLOGY_PRIORITY"topology.priority"public static final StringTOPOLOGY_PRODUCER_BATCH_SIZE"topology.producer.batch.size"public static final StringTOPOLOGY_RAS_ACKER_EXECUTORS_PER_WORKER"topology.ras.acker.executors.per.worker"public static final StringTOPOLOGY_RAS_CONSTRAINT_MAX_STATE_SEARCH"topology.ras.constraint.max.state.search"public static final StringTOPOLOGY_RAS_CONSTRAINT_MAX_TIME_SECS"topology.ras.constraint.max.time.secs"public static final StringTOPOLOGY_RAS_CONSTRAINTS"topology.ras.constraints"public static final StringTOPOLOGY_RAS_ONE_COMPONENT_PER_WORKER"topology.ras.one.component.per.worker"public static final StringTOPOLOGY_RAS_ONE_EXECUTOR_PER_WORKER"topology.ras.one.executor.per.worker"public static final StringTOPOLOGY_RAS_ORDER_EXECUTORS_BY_PROXIMITY_NEEDS"topology.ras.order.executors.by.proximity.needs"public static final StringTOPOLOGY_READONLY_GROUPS"topology.readonly.groups"public static final StringTOPOLOGY_READONLY_USERS"topology.readonly.users"public static final StringTOPOLOGY_SCHEDULER_FAVORED_NODES"topology.scheduler.favored.nodes"public static final StringTOPOLOGY_SCHEDULER_STRATEGY"topology.scheduler.strategy"public static final StringTOPOLOGY_SCHEDULER_UNFAVORED_NODES"topology.scheduler.unfavored.nodes"public static final StringTOPOLOGY_SERIALIZED_MESSAGE_SIZE_METRICS"topology.serialized.message.size.metrics"public static final StringTOPOLOGY_SHELLBOLT_MAX_PENDING"topology.shellbolt.max.pending"public static final StringTOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS"topology.skip.missing.kryo.registrations"public static final StringTOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS"topology.sleep.spout.wait.strategy.time.ms"public static final StringTOPOLOGY_SPOUT_RECVQ_SKIPS"topology.spout.recvq.skips"public static final StringTOPOLOGY_SPOUT_WAIT_PARK_MICROSEC"topology.spout.wait.park.microsec"public static final StringTOPOLOGY_SPOUT_WAIT_PROGRESSIVE_LEVEL1_COUNT"topology.spout.wait.progressive.level1.count"public static final StringTOPOLOGY_SPOUT_WAIT_PROGRESSIVE_LEVEL2_COUNT"topology.spout.wait.progressive.level2.count"public static final StringTOPOLOGY_SPOUT_WAIT_PROGRESSIVE_LEVEL3_SLEEP_MILLIS"topology.spout.wait.progressive.level3.sleep.millis"public static final StringTOPOLOGY_SPOUT_WAIT_STRATEGY"topology.spout.wait.strategy"public static final StringTOPOLOGY_SPREAD_COMPONENTS"topology.spread.components"public static final StringTOPOLOGY_STATE_CHECKPOINT_INTERVAL"topology.state.checkpoint.interval.ms"public static final StringTOPOLOGY_STATE_KRYO_REGISTER"topology.state.kryo.register"public static final StringTOPOLOGY_STATE_PROVIDER"topology.state.provider"public static final StringTOPOLOGY_STATE_PROVIDER_CONFIG"topology.state.provider.config"public static final StringTOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS"topology.state.synchronization.timeout.secs"public static final StringTOPOLOGY_STATS_SAMPLE_RATE"topology.stats.sample.rate"public static final StringTOPOLOGY_SUBMITTER_PRINCIPAL"topology.submitter.principal"public static final StringTOPOLOGY_SUBMITTER_USER"topology.submitter.user"public static final StringTOPOLOGY_SUBPROCESS_TIMEOUT_SECS"topology.subprocess.timeout.secs"public static final StringTOPOLOGY_TASKS"topology.tasks"public static final StringTOPOLOGY_TESTING_ALWAYS_TRY_SERIALIZE"topology.testing.always.try.serialize"public static final StringTOPOLOGY_TICK_TUPLE_FREQ_SECS"topology.tick.tuple.freq.secs"public static final StringTOPOLOGY_TRANSACTIONAL_ID"topology.transactional.id"public static final StringTOPOLOGY_TRANSFER_BATCH_SIZE"topology.transfer.batch.size"public static final StringTOPOLOGY_TRANSFER_BUFFER_SIZE"topology.transfer.buffer.size"public static final StringTOPOLOGY_TRIDENT_BATCH_EMIT_INTERVAL_MILLIS"topology.trident.batch.emit.interval.millis"public static final StringTOPOLOGY_TRIDENT_WINDOWING_INMEMORY_CACHE_LIMIT"topology.trident.windowing.cache.tuple.limit"public static final StringTOPOLOGY_TUPLE_SERIALIZER"topology.tuple.serializer"public static final StringTOPOLOGY_USERS"topology.users"public static final StringTOPOLOGY_V2_METRICS_TICK_INTERVAL_SECONDS"topology.v2.metrics.tick.interval.seconds"public static final StringTOPOLOGY_VERSION"topology.version"public static final StringTOPOLOGY_WORKER_CHILDOPTS"topology.worker.childopts"public static final StringTOPOLOGY_WORKER_GC_CHILDOPTS"topology.worker.gc.childopts"public static final StringTOPOLOGY_WORKER_LOGWRITER_CHILDOPTS"topology.worker.logwriter.childopts"public static final StringTOPOLOGY_WORKER_MAX_HEAP_SIZE_MB"topology.worker.max.heap.size.mb"public static final StringTOPOLOGY_WORKER_METRICS"topology.worker.metrics"public static final StringTOPOLOGY_WORKER_NIMBUS_THRIFT_CLIENT_USE_TLS"topology.worker.nimbus.thrift.client.use.tls"public static final StringTOPOLOGY_WORKER_SHARED_THREAD_POOL_SIZE"topology.worker.shared.thread.pool.size"public static final StringTOPOLOGY_WORKER_TIMEOUT_SECS"topology.worker.timeout.secs"public static final StringTOPOLOGY_WORKERS"topology.workers"public static final StringTRANSACTIONAL_ZOOKEEPER_PORT"transactional.zookeeper.port"public static final StringTRANSACTIONAL_ZOOKEEPER_ROOT"transactional.zookeeper.root"public static final StringTRANSACTIONAL_ZOOKEEPER_SERVERS"transactional.zookeeper.servers"public static final StringWORKER_BLOB_UPDATE_POLL_INTERVAL_SECS"worker.blob.update.poll.interval.secs"public static final StringWORKER_CHILDOPTS"worker.childopts"public static final StringWORKER_GC_CHILDOPTS"worker.gc.childopts"public static final StringWORKER_HEAP_MEMORY_MB"worker.heap.memory.mb"public static final StringWORKER_HEARTBEAT_FREQUENCY_SECS"worker.heartbeat.frequency.secs"public static final StringWORKER_LOG_LEVEL_RESET_POLL_SECS"worker.log.level.reset.poll.secs"public static final StringWORKER_MAX_TIMEOUT_SECS"worker.max.timeout.secs"public static final StringWORKER_METRICS"worker.metrics"public static final StringZK_SSL_ENABLE"storm.zookeeper.ssl.enable" -
org.apache.storm.Constants Modifier and Type Constant Field Value public static final StringCOMMON_CPU_RESOURCE_NAME"cpu.pcore.percent"public static final StringCOMMON_OFFHEAP_MEMORY_RESOURCE_NAME"offheap.memory.mb"public static final StringCOMMON_ONHEAP_MEMORY_RESOURCE_NAME"onheap.memory.mb"public static final StringCOMMON_TOTAL_MEMORY_RESOURCE_NAME"memory.mb"public static final StringCOMPONENT_TO_DEBUG_ATOM"storm-component->debug-atom"public static final StringCOMPONENT_TO_SORTED_TASKS"component->sorted-tasks"public static final StringCOMPONENT_TO_STREAM_TO_FIELDS"component->stream->fields"public static final StringCONF"conf"public static final StringDEFAULT_SHARED_RESOURCES"default-shared-resources"public static final StringEXECUTOR_RECEIVE_QUEUE_MAP"executor-receive-queue-map"public static final StringMETRICS_COMPONENT_ID_PREFIX"__metrics_"public static final StringMETRICS_STREAM_ID"__metrics"public static final StringMETRICS_TICK_STREAM_ID"__metrics_tick"public static final StringNIMBUS_SEND_ASSIGNMENT_EXCEPTIONS"nimbus:num-send-assignment-exceptions"public static final StringPORT"port"public static final StringSTORM_ACTIVE_ATOM"storm-active-atom"public static final StringSTORM_CONF"storm-conf"public static final StringSTORM_ID"storm-id"public static final StringSUICIDE_FN"suicide-fn"public static final StringSUPERVISOR_HEALTH_CHECK_TIMEOUTS"supervisor:health-check-timeouts"public static final StringSYSTEM_COMPONENT_ID"__system"public static final StringSYSTEM_FLUSH_STREAM_ID"__flush"public static final longSYSTEM_TASK_ID-1Lpublic static final StringSYSTEM_TICK_STREAM_ID"__tick"public static final StringSYSTEM_TOPOLOGY"system-topology"public static final StringTASK_IDS"task-ids"public static final StringTASK_TO_COMPONENT"task->component"public static final StringTRANSFER_FN"transfer-fn"public static final StringUSER_SHARED_RESOURCES"user-shared-resources"public static final StringUSER_TIMER"user-timer"public static final StringWORKER_ID"worker-id"public static final StringWORKER_METRICS_REGISTRY"worker-metrics-registry" -
org.apache.storm.DaemonConfig Modifier and Type Constant Field Value public static final StringBLACKLIST_SCHEDULER_ASSUME_SUPERVISOR_BAD_BASED_ON_BAD_SLOT"blacklist.scheduler.assume.supervisor.bad.based.on.bad.slot"public static final StringBLACKLIST_SCHEDULER_ENABLE_SEND_ASSIGNMENT_FAILURES"blacklist.scheduler.enable.send.assignment.failures"public static final StringBLACKLIST_SCHEDULER_REPORTER"blacklist.scheduler.reporter"public static final StringBLACKLIST_SCHEDULER_RESUME_TIME"blacklist.scheduler.resume.time.secs"public static final StringBLACKLIST_SCHEDULER_STRATEGY"blacklist.scheduler.strategy"public static final StringBLACKLIST_SCHEDULER_TOLERANCE_COUNT"blacklist.scheduler.tolerance.count"public static final StringBLACKLIST_SCHEDULER_TOLERANCE_TIME"blacklist.scheduler.tolerance.time.secs"public static final StringDEV_ZOOKEEPER_PATH"dev.zookeeper.path"public static final StringDRPC_AUTHORIZER"drpc.authorizer"public static final StringDRPC_CHILDOPTS"drpc.childopts"public static final StringDRPC_DISABLE_HTTP_BINDING"drpc.disable.http.binding"public static final StringDRPC_HTTP_CREDS_PLUGIN"drpc.http.creds.plugin"public static final StringDRPC_HTTP_FILTER"drpc.http.filter"public static final StringDRPC_HTTP_FILTER_PARAMS"drpc.http.filter.params"public static final StringDRPC_HTTP_PORT"drpc.http.port"public static final StringDRPC_HTTPS_ENABLE_SSL_RELOAD"drpc.https.enable.ssl.reload"public static final StringDRPC_HTTPS_KEY_PASSWORD"drpc.https.key.password"public static final StringDRPC_HTTPS_KEYSTORE_PASSWORD"drpc.https.keystore.password"public static final StringDRPC_HTTPS_KEYSTORE_PATH"drpc.https.keystore.path"public static final StringDRPC_HTTPS_KEYSTORE_TYPE"drpc.https.keystore.type"public static final StringDRPC_HTTPS_NEED_CLIENT_AUTH"drpc.https.need.client.auth"public static final StringDRPC_HTTPS_PORT"drpc.https.port"public static final StringDRPC_HTTPS_TRUSTSTORE_PASSWORD"drpc.https.truststore.password"public static final StringDRPC_HTTPS_TRUSTSTORE_PATH"drpc.https.truststore.path"public static final StringDRPC_HTTPS_TRUSTSTORE_TYPE"drpc.https.truststore.type"public static final StringDRPC_HTTPS_WANT_CLIENT_AUTH"drpc.https.want.client.auth"public static final StringDRPC_REQUEST_TIMEOUT_SECS"drpc.request.timeout.secs"public static final StringISOLATION_SCHEDULER_MACHINES"isolation.scheduler.machines"public static final StringJAVA_LIBRARY_PATH"java.library.path"public static final StringLOGS_GROUPS"logs.groups"public static final StringLOGS_USERS"logs.users"public static final StringLOGVIEWER_APPENDER_NAME"logviewer.appender.name"public static final StringLOGVIEWER_CHILDOPTS"logviewer.childopts"public static final StringLOGVIEWER_CLEANUP_AGE_MINS"logviewer.cleanup.age.mins"public static final StringLOGVIEWER_CLEANUP_INTERVAL_SECS"logviewer.cleanup.interval.secs"public static final StringLOGVIEWER_DISABLE_HTTP_BINDING"logviewer.disable.http.binding"public static final StringLOGVIEWER_FILTER"logviewer.filter"public static final StringLOGVIEWER_FILTER_PARAMS"logviewer.filter.params"public static final StringLOGVIEWER_HTTPS_ENABLE_SSL_RELOAD"logviewer.https.enable.ssl.reload"public static final StringLOGVIEWER_HTTPS_KEY_PASSWORD"logviewer.https.key.password"public static final StringLOGVIEWER_HTTPS_KEYSTORE_PASSWORD"logviewer.https.keystore.password"public static final StringLOGVIEWER_HTTPS_KEYSTORE_PATH"logviewer.https.keystore.path"public static final StringLOGVIEWER_HTTPS_KEYSTORE_TYPE"logviewer.https.keystore.type"public static final StringLOGVIEWER_HTTPS_NEED_CLIENT_AUTH"logviewer.https.need.client.auth"public static final StringLOGVIEWER_HTTPS_PORT"logviewer.https.port"public static final StringLOGVIEWER_HTTPS_TRUSTSTORE_PASSWORD"logviewer.https.truststore.password"public static final StringLOGVIEWER_HTTPS_TRUSTSTORE_PATH"logviewer.https.truststore.path"public static final StringLOGVIEWER_HTTPS_TRUSTSTORE_TYPE"logviewer.https.truststore.type"public static final StringLOGVIEWER_HTTPS_WANT_CLIENT_AUTH"logviewer.https.want.client.auth"public static final StringLOGVIEWER_MAX_PER_WORKER_LOGS_SIZE_MB"logviewer.max.per.worker.logs.size.mb"public static final StringLOGVIEWER_MAX_SUM_WORKER_LOGS_SIZE_MB"logviewer.max.sum.worker.logs.size.mb"public static final StringLOGVIEWER_PORT"logviewer.port"public static final StringMULTITENANT_SCHEDULER_USER_POOLS"multitenant.scheduler.user.pools"public static final StringNIMBUS_ASSIGNMENTS_SERVICE_THREAD_QUEUE_SIZE"nimbus.assignments.service.thread.queue.size"public static final StringNIMBUS_ASSIGNMENTS_SERVICE_THREADS"nimbus.assignments.service.threads"public static final StringNIMBUS_AUTHORIZER"nimbus.authorizer"public static final StringNIMBUS_BLOBSTORE"nimbus.blobstore.class"public static final StringNIMBUS_BLOBSTORE_EXPIRATION_SECS"nimbus.blobstore.expiration.secs"public static final StringNIMBUS_CHILDOPTS"nimbus.childopts"public static final StringNIMBUS_CLEANUP_INBOX_FREQ_SECS"nimbus.cleanup.inbox.freq.secs"public static final StringNIMBUS_CODE_SYNC_FREQ_SECS"nimbus.code.sync.freq.secs"public static final StringNIMBUS_CREDENTIAL_RENEW_FREQ_SECS"nimbus.credential.renewers.freq.secs"public static final StringNIMBUS_DAEMON_USER"nimbus.daemon.user"public static final StringNIMBUS_EXECUTORS_PER_TOPOLOGY"nimbus.executors.perTopology"public static final StringNIMBUS_FILE_COPY_EXPIRATION_SECS"nimbus.file.copy.expiration.secs"public static final StringNIMBUS_IMPERSONATION_AUTHORIZER"nimbus.impersonation.authorizer"public static final StringNIMBUS_INBOX_JAR_EXPIRATION_SECS"nimbus.inbox.jar.expiration.secs"public static final StringNIMBUS_MONITOR_FREQ_SECS"nimbus.monitor.freq.secs"public static final StringNIMBUS_SLOTS_PER_TOPOLOGY"nimbus.slots.perTopology"public static final StringNIMBUS_SUPERVISOR_TIMEOUT_SECS"nimbus.supervisor.timeout.secs"public static final StringNIMBUS_TASK_LAUNCH_SECS"nimbus.task.launch.secs"public static final StringNIMBUS_TASK_TIMEOUT_SECS"nimbus.task.timeout.secs"public static final StringNIMBUS_TOPOLOGY_ACTION_NOTIFIER_PLUGIN"nimbus.topology.action.notifier.plugin.class"public static final StringNIMBUS_TOPOLOGY_BLOBSTORE_DELETION_DELAY_MS"nimbus.topology.blobstore.deletion.delay.ms"public static final StringNIMBUS_TOPOLOGY_VALIDATOR"nimbus.topology.validator"public static final StringNIMBUS_WORKER_HEARTBEATS_RECOVERY_STRATEGY_CLASS"nimbus.worker.heartbeats.recovery.strategy.class"public static final StringPACEMAKER_CHILDOPTS"pacemaker.childopts"public static final StringPACEMAKER_MAX_THREADS"pacemaker.max.threads"public static final StringRESOURCE_AWARE_SCHEDULER_MAX_STATE_SEARCH"resource.aware.scheduler.constraint.max.state.search"public static final StringRESOURCE_AWARE_SCHEDULER_MAX_TOPOLOGY_SCHEDULING_ATTEMPTS"resource.aware.scheduler.max.topology.scheduling.attempts"public static final StringRESOURCE_AWARE_SCHEDULER_PRIORITY_STRATEGY"resource.aware.scheduler.priority.strategy"public static final StringRESOURCE_AWARE_SCHEDULER_USER_POOLS"resource.aware.scheduler.user.pools"public static final StringSCHEDULER_CONFIG_CACHE_EXPIRATION_SECS"scheduler.config.cache.expiration.secs"public static final StringSCHEDULER_CONFIG_LOADER_ARTIFACTORY_BASE_DIRECTORY"scheduler.config.loader.artifactory.base.directory"public static final StringSCHEDULER_CONFIG_LOADER_POLLTIME_SECS"scheduler.config.loader.polltime.secs"public static final StringSCHEDULER_CONFIG_LOADER_TIMEOUT_SECS"scheduler.config.loader.timeout.secs"public static final StringSCHEDULER_CONFIG_LOADER_URI"scheduler.config.loader.uri"public static final StringSCHEDULER_DISPLAY_RESOURCE"scheduler.display.resource"public static final StringSCHEDULING_TIMEOUT_SECONDS_PER_TOPOLOGY"scheduling.timeout.seconds.per.topology"public static final StringSTORM_CGROUP_HIERARCHY_NAME"storm.cgroup.hierarchy.name"public static final StringSTORM_CGROUP_RESOURCES"storm.cgroup.resources"public static final StringSTORM_CLUSTER_METRICS_CONSUMER_PUBLISH_INTERVAL_SECS"storm.cluster.metrics.consumer.publish.interval.secs"public static final StringSTORM_CLUSTER_METRICS_CONSUMER_REGISTER"storm.cluster.metrics.consumer.register"public static final StringSTORM_DAEMON_METRICS_REPORTER_CSV_LOG_DIR"storm.daemon.metrics.reporter.csv.log.dir"public static final StringSTORM_DAEMON_METRICS_REPORTER_INTERVAL_SECS"storm.daemon.metrics.reporter.interval.secs"public static final StringSTORM_DAEMON_METRICS_REPORTER_PLUGIN_DOMAIN"storm.daemon.metrics.reporter.plugin.domain"public static final StringSTORM_DAEMON_METRICS_REPORTER_PLUGINS"storm.daemon.metrics.reporter.plugins"public static final StringSTORM_HEALTH_CHECK_DIR"storm.health.check.dir"public static final StringSTORM_HEALTH_CHECK_FAIL_ON_TIMEOUTS"storm.health.check.fail.on.timeouts"public static final StringSTORM_HEALTH_CHECK_TIMEOUT_MS"storm.health.check.timeout.ms"public static final StringSTORM_LOG4J2_CONF_DIR"storm.log4j2.conf.dir"public static final StringSTORM_METRIC_PROCESSOR_CLASS"storm.metricprocessor.class"public static final StringSTORM_METRIC_STORE_CLASS"storm.metricstore.class"public static final StringSTORM_NETTY_FLUSH_CHECK_INTERVAL_MS"storm.messaging.netty.flush.check.interval.ms"public static final StringSTORM_NIMBUS_ZOOKEEPER_ACLS_CHECK"storm.nimbus.zookeeper.acls.check"public static final StringSTORM_NIMBUS_ZOOKEEPER_ACLS_FIXUP"storm.nimbus.zookeeper.acls.fixup"public static final StringSTORM_OCI_IMAGE_TAG_TO_MANIFEST_PLUGIN"storm.oci.image.tag.to.manifest.plugin"public static final StringSTORM_OCI_LAYER_MOUNTS_TO_KEEP"storm.oci.layer.mounts.to.keep"public static final StringSTORM_OCI_MANIFEST_TO_RESOURCES_PLUGIN"storm.oci.manifest.to.resources.plugin"public static final StringSTORM_OCI_RESOURCES_LOCAL_DIR"storm.oci.resources.local.dir"public static final StringSTORM_OCI_RESOURCES_LOCALIZER"storm.oci.resources.localizer"public static final StringSTORM_RESOURCE_ISOLATION_PLUGIN"storm.resource.isolation.plugin"public static final StringSTORM_RESOURCE_ISOLATION_PLUGIN_ENABLE"storm.resource.isolation.plugin.enable"public static final StringSTORM_ROCKSDB_CREATE_IF_MISSING"storm.metricstore.rocksdb.create_if_missing"public static final StringSTORM_ROCKSDB_LOCATION"storm.metricstore.rocksdb.location"public static final StringSTORM_ROCKSDB_METADATA_STRING_CACHE_CAPACITY"storm.metricstore.rocksdb.metadata_string_cache_capacity"public static final StringSTORM_ROCKSDB_METRIC_DELETION_PERIOD_HOURS"storm.metricstore.rocksdb.deletion_period_hours"public static final StringSTORM_ROCKSDB_METRIC_RETENTION_HOURS"storm.metricstore.rocksdb.retention_hours"public static final StringSTORM_SCHEDULER"storm.scheduler"public static final StringSTORM_TOPOLOGY_CLASSPATH_BEGINNING_ENABLED"storm.topology.classpath.beginning.enabled"public static final StringSUPERVISOR_AUTHORIZER"supervisor.authorizer"public static final StringSUPERVISOR_BLOBSTORE"supervisor.blobstore.class"public static final StringSUPERVISOR_BLOBSTORE_DOWNLOAD_MAX_RETRIES"supervisor.blobstore.download.max_retries"public static final StringSUPERVISOR_BLOBSTORE_DOWNLOAD_THREAD_COUNT"supervisor.blobstore.download.thread.count"public static final StringSUPERVISOR_CHILDOPTS"supervisor.childopts"public static final StringSUPERVISOR_ENABLE"supervisor.enable"public static final StringSUPERVISOR_HEARTBEAT_FREQUENCY_SECS"supervisor.heartbeat.frequency.secs"public static final StringSUPERVISOR_LOCALIZER_CACHE_CLEANUP_INTERVAL_MS"supervisor.localizer.cleanup.interval.ms"public static final StringSUPERVISOR_LOCALIZER_CACHE_TARGET_SIZE_MB"supervisor.localizer.cache.target.size.mb"public static final StringSUPERVISOR_LOCALIZER_UPDATE_BLOB_INTERVAL_SECS"supervisor.localizer.update.blob.interval.secs"public static final StringSUPERVISOR_MONITOR_FREQUENCY_SECS"supervisor.monitor.frequency.secs"public static final StringSUPERVISOR_NUMA_META"supervisor.numa.meta"public static final StringSUPERVISOR_SCHEDULER_META"supervisor.scheduler.meta"public static final StringSUPERVISOR_SLOTS_PORTS"supervisor.slots.ports"public static final StringSUPERVISOR_WORKER_START_TIMEOUT_SECS"supervisor.worker.start.timeout.secs"public static final StringUI_CENTRAL_LOGGING_URL"ui.central.logging.url"public static final StringUI_CHILDOPTS"ui.childopts"public static final StringUI_DISABLE_HTTP_BINDING"ui.disable.http.binding"public static final StringUI_DISABLE_SPOUT_LAG_MONITORING"ui.disable.spout.lag.monitoring"public static final StringUI_FILTER"ui.filter"public static final StringUI_FILTER_PARAMS"ui.filter.params"public static final StringUI_HEADER_BUFFER_BYTES"ui.header.buffer.bytes"public static final StringUI_HOST"ui.host"public static final StringUI_HTTP_CREDS_PLUGIN"ui.http.creds.plugin"public static final StringUI_HTTPS_ENABLE_SSL_RELOAD"ui.https.enable.ssl.reload"public static final StringUI_HTTPS_KEY_PASSWORD"ui.https.key.password"public static final StringUI_HTTPS_KEYSTORE_PASSWORD"ui.https.keystore.password"public static final StringUI_HTTPS_KEYSTORE_PATH"ui.https.keystore.path"public static final StringUI_HTTPS_KEYSTORE_TYPE"ui.https.keystore.type"public static final StringUI_HTTPS_NEED_CLIENT_AUTH"ui.https.need.client.auth"public static final StringUI_HTTPS_PORT"ui.https.port"public static final StringUI_HTTPS_TRUSTSTORE_PASSWORD"ui.https.truststore.password"public static final StringUI_HTTPS_TRUSTSTORE_PATH"ui.https.truststore.path"public static final StringUI_HTTPS_TRUSTSTORE_TYPE"ui.https.truststore.type"public static final StringUI_HTTPS_WANT_CLIENT_AUTH"ui.https.want.client.auth"public static final StringUI_PAGINATION"ui.pagination"public static final StringUI_PORT"ui.port"public static final StringUI_PROJECT_BUGTRACKER_URL"ui.project.bugtracker.url"public static final StringUI_TITLE"ui.title"public static final StringVALIDATE_TOPOLOGY_SCHEDULER_STRATEGY"topology.scheduler.strategy"public static final StringWORKER_PROFILER_CHILDOPTS"worker.profiler.childopts"public static final StringWORKER_PROFILER_COMMAND"worker.profiler.command"public static final StringWORKER_PROFILER_ENABLED"worker.profiler.enabled" -
org.apache.storm.ExclamationTopology Modifier and Type Constant Field Value public static final StringEXCLAIM_1"exclaim1"public static final StringEXCLAIM_2"exclaim2"public static final intEXCLAIM_2_EXECUTORS2public static final intSPOUT_EXECUTORS10public static final StringWORD"word" -
org.apache.storm.ServerConstants Modifier and Type Constant Field Value public static final StringNUMA_CORES"numa.cores"public static final StringNUMA_GENERIC_RESOURCES_MAP"numa.generic.resources.map"public static final StringNUMA_ID_SEPARATOR"-numa-"public static final StringNUMA_MEMORY_IN_MB"numa.memory.mb"public static final StringNUMA_PORTS"numa.ports"
-
org.apache.storm.blobstore.BlobStore Modifier and Type Constant Field Value protected static final StringBASE_BLOBS_DIR_NAME"blobs" -
org.apache.storm.blobstore.BlobStoreAclHandler Modifier and Type Constant Field Value public static final intADMIN4public static final intREAD1public static final intWRITE2 -
org.apache.storm.blobstore.BlobStoreFile Modifier and Type Constant Field Value protected static final StringBLOBSTORE_DATA_FILE"data"protected static final StringTMP_EXT".tmp"
-
org.apache.storm.cluster.ClusterUtils Modifier and Type Constant Field Value public static final StringASSIGNMENTS_ROOT"assignments"public static final StringASSIGNMENTS_SUBTREE"/assignments"public static final StringBACKPRESSURE_ROOT"backpressure"public static final StringBACKPRESSURE_SUBTREE"/backpressure"public static final StringBLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_ROOT"blobstoremaxkeysequencenumber"public static final StringBLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_SUBTREE"/blobstoremaxkeysequencenumber"public static final StringBLOBSTORE_ROOT"blobstore"public static final StringBLOBSTORE_SUBTREE"/blobstore"public static final StringCREDENTIALS_ROOT"credentials"public static final StringCREDENTIALS_SUBTREE"/credentials"public static final StringERRORS_ROOT"errors"public static final StringERRORS_SUBTREE"/errors"public static final StringLEADERINFO_ROOT"leader-info"public static final StringLEADERINFO_SUBTREE"/leader-info"public static final StringLOGCONFIG_ROOT"logconfigs"public static final StringLOGCONFIG_SUBTREE"/logconfigs"public static final StringNIMBUSES_ROOT"nimbuses"public static final StringNIMBUSES_SUBTREE"/nimbuses"public static final StringPROFILERCONFIG_ROOT"profilerconfigs"public static final StringPROFILERCONFIG_SUBTREE"/profilerconfigs"public static final StringSECRET_KEYS_ROOT"secretkeys"public static final StringSECRET_KEYS_SUBTREE"/secretkeys"public static final StringSTORMS_ROOT"storms"public static final StringSTORMS_SUBTREE"/storms"public static final StringSUPERVISORS_ROOT"supervisors"public static final StringSUPERVISORS_SUBTREE"/supervisors"public static final StringWORKERBEATS_ROOT"workerbeats"public static final StringWORKERBEATS_SUBTREE"/workerbeats"public static final StringZK_SEPERATOR"/"
-
org.apache.storm.common.AbstractHadoopNimbusPluginAutoCreds Modifier and Type Constant Field Value public static final StringCONFIG_KEY_RESOURCES"resources"
-
org.apache.storm.container.cgroup.CgroupCommon Modifier and Type Constant Field Value public static final StringCGROUP_CLONE_CHILDREN"/cgroup.clone_children"public static final StringCGROUP_EVENT_CONTROL"/cgroup.event_control"public static final StringCGROUP_PROCS"/cgroup.procs"public static final StringNOTIFY_ON_RELEASE"/notify_on_release"public static final StringRELEASE_AGENT"/release_agent"public static final StringTASKS"/tasks" -
org.apache.storm.container.cgroup.CgroupUtils Modifier and Type Constant Field Value public static final StringCGROUP_STATUS_FILE"/proc/cgroups"public static final StringMOUNT_STATUS_FILE"/proc/mounts"
-
org.apache.storm.container.cgroup.core.BlkioCore Modifier and Type Constant Field Value public static final StringBLKIO_IO_MERGED"/blkio.io_merged"public static final StringBLKIO_IO_QUEUED"/blkio.io_queued"public static final StringBLKIO_IO_SERVICE_BYTES"/blkio.io_service_bytes"public static final StringBLKIO_IO_SERVICE_TIME"/blkio.io_service_time"public static final StringBLKIO_IO_SERVICED"/blkio.io_serviced"public static final StringBLKIO_IO_WAIT_TIME"/blkio.io_wait_time"public static final StringBLKIO_RESET_STATS"/blkio.reset_stats"public static final StringBLKIO_SECTORS"/blkio.sectors"public static final StringBLKIO_THROTTLE_IO_SERVICE_BYTES"/blkio.throttle.io_service_bytes"public static final StringBLKIO_THROTTLE_IO_SERVICED"/blkio.throttle.io_serviced"public static final StringBLKIO_THROTTLE_READ_BPS_DEVICE"/blkio.throttle.read_bps_device"public static final StringBLKIO_THROTTLE_READ_IOPS_DEVICE"/blkio.throttle.read_iops_device"public static final StringBLKIO_THROTTLE_WRITE_BPS_DEVICE"/blkio.throttle.write_bps_device"public static final StringBLKIO_THROTTLE_WRITE_IOPS_DEVICE"/blkio.throttle.write_iops_device"public static final StringBLKIO_TIME"/blkio.time"public static final StringBLKIO_WEIGHT"/blkio.weight"public static final StringBLKIO_WEIGHT_DEVICE"/blkio.weight_device" -
org.apache.storm.container.cgroup.core.CpuacctCore Modifier and Type Constant Field Value public static final StringCPUACCT_STAT"/cpuacct.stat"public static final StringCPUACCT_USAGE"/cpuacct.usage"public static final StringCPUACCT_USAGE_PERCPU"/cpuacct.usage_percpu" -
org.apache.storm.container.cgroup.core.CpuCore Modifier and Type Constant Field Value public static final StringCPU_CFS_PERIOD_US"/cpu.cfs_period_us"public static final StringCPU_CFS_QUOTA_US"/cpu.cfs_quota_us"public static final StringCPU_RT_PERIOD_US"/cpu.rt_period_us"public static final StringCPU_RT_RUNTIME_US"/cpu.rt_runtime_us"public static final StringCPU_SHARES"/cpu.shares"public static final StringCPU_STAT"/cpu.stat" -
org.apache.storm.container.cgroup.core.CpusetCore Modifier and Type Constant Field Value public static final StringCPUSET_CPU_EXCLUSIVE"/cpuset.cpu_exclusive"public static final StringCPUSET_CPUS"/cpuset.cpus"public static final StringCPUSET_MEM_EXCLUSIVE"/cpuset.mem_exclusive"public static final StringCPUSET_MEM_HARDWALL"/cpuset.mem_hardwall"public static final StringCPUSET_MEMORY_MIGRATE"/cpuset.memory_migrate"public static final StringCPUSET_MEMORY_PRESSURE"/cpuset.memory_pressure"public static final StringCPUSET_MEMORY_PRESSURE_ENABLED"/cpuset.memory_pressure_enabled"public static final StringCPUSET_MEMORY_SPREAD_PAGE"/cpuset.memory_spread_page"public static final StringCPUSET_MEMORY_SPREAD_SLAB"/cpuset.memory_spread_slab"public static final StringCPUSET_MEMS"/cpuset.mems"public static final StringCPUSET_SCHED_LOAD_BALANCE"/cpuset.sched_load_balance"public static final StringCPUSET_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 StringFREEZER_STATE"/freezer.state" -
org.apache.storm.container.cgroup.core.MemoryCore Modifier and Type Constant Field Value public static final StringMEMORY_FAILCNT"/memory.failcnt"public static final StringMEMORY_FORCE_EMPTY"/memory.force_empty"public static final StringMEMORY_LIMIT_IN_BYTES"/memory.limit_in_bytes"public static final StringMEMORY_MAX_USAGE_IN_BYTES"/memory.max_usage_in_bytes"public static final StringMEMORY_MEMSW_FAILCNT"/memory.memsw.failcnt"public static final StringMEMORY_MEMSW_LIMIT_IN_BYTES"/memory.memsw.limit_in_bytes"public static final StringMEMORY_MEMSW_MAX_USAGE_IN_BYTES"/memory.memsw.max_usage_in_bytes"public static final StringMEMORY_MEMSW_USAGE_IN_BYTES"/memory.memsw.usage_in_bytes"public static final StringMEMORY_OOM_CONTROL"/memory.oom_control"public static final StringMEMORY_STAT"/memory.stat"public static final StringMEMORY_SWAPPINESS"/memory.swappiness"public static final StringMEMORY_USAGE_IN_BYTES"/memory.usage_in_bytes"public static final StringMEMORY_USE_HIERARCHY"/memory.use_hierarchy" -
org.apache.storm.container.cgroup.core.NetClsCore Modifier and Type Constant Field Value public static final StringNET_CLS_CLASSID"/net_cls.classid" -
org.apache.storm.container.cgroup.core.NetPrioCore Modifier and Type Constant Field Value public static final StringNET_PRIO_IFPRIOMAP"/net_prio.ifpriomap"public static final StringNET_PRIO_PRIOIDX"/net_prio.prioidx"
-
org.apache.storm.daemon.Acker Modifier and Type Constant Field Value public static final StringACKER_ACK_STREAM_ID"__ack_ack"public static final StringACKER_COMPONENT_ID"__acker"public static final StringACKER_FAIL_STREAM_ID"__ack_fail"public static final StringACKER_INIT_STREAM_ID"__ack_init"public static final StringACKER_RESET_TIMEOUT_STREAM_ID"__ack_reset_timeout"public static final intTIMEOUT_BUCKET_NUM3 -
org.apache.storm.daemon.StormCommon Modifier and Type Constant Field Value public static final StringEVENTLOGGER_COMPONENT_ID"__eventlogger"public static final StringEVENTLOGGER_STREAM_ID"__eventlog"public static final StringSYSTEM_STREAM_ID"__system"public static final StringTOPOLOGY_EVENT_LOGGER_ARGUMENTS"arguments"public static final StringTOPOLOGY_EVENT_LOGGER_CLASS"class"public static final StringTOPOLOGY_METRICS_CONSUMER_ARGUMENT"argument"public static final StringTOPOLOGY_METRICS_CONSUMER_BLACKLIST"blacklist"public static final StringTOPOLOGY_METRICS_CONSUMER_CLASS"class"public static final StringTOPOLOGY_METRICS_CONSUMER_EXPAND_MAP_TYPE"expandMapType"public static final StringTOPOLOGY_METRICS_CONSUMER_MAX_RETAIN_METRIC_TUPLES"max.retain.metric.tuples"public static final StringTOPOLOGY_METRICS_CONSUMER_METRIC_NAME_SEPARATOR"metricNameSeparator"public static final StringTOPOLOGY_METRICS_CONSUMER_PARALLELISM_HINT"parallelism.hint"public static final StringTOPOLOGY_METRICS_CONSUMER_WHITELIST"whitelist"
-
org.apache.storm.daemon.logviewer.LogviewerConstant Modifier and Type Constant Field Value public static final intDEFAULT_BYTES_PER_PAGE51200
-
org.apache.storm.daemon.logviewer.handler.LogviewerLogSearchHandler Modifier and Type Constant Field Value public static final intGREP_BUF_SIZE2048public static final intGREP_CONTEXT_SIZE128public static final intGREP_MAX_SEARCH_SIZE1024 -
org.apache.storm.daemon.logviewer.handler.LogviewerProfileHandler Modifier and Type Constant Field Value public static final StringWORKER_LOG_FILENAME"worker.log"
-
org.apache.storm.daemon.logviewer.utils.DirectoryCleaner Modifier and Type Constant Field Value public static final intMAX_NUMBER_OF_FILES_FOR_DIR1024 -
org.apache.storm.daemon.logviewer.utils.ExceptionMeterNames Modifier and Type Constant Field Value public static final StringNUM_CLEANUP_EXCEPTIONS"logviewer:num-other-cleanup-exceptions"public static final StringNUM_DOWNLOAD_DAEMON_LOG_EXCEPTIONS"logviewer:num-download-daemon-log-exceptions"public static final StringNUM_DOWNLOAD_DUMP_EXCEPTIONS"logviewer:num-download-dump-exceptions"public static final StringNUM_DOWNLOAD_LOG_EXCEPTIONS"logviewer:num-download-log-exceptions"public static final StringNUM_FILE_DOWNLOAD_EXCEPTIONS"logviewer:num-file-download-exceptions"public static final StringNUM_FILE_OPEN_EXCEPTIONS"logviewer:num-file-open-exceptions"public static final StringNUM_FILE_READ_EXCEPTIONS"logviewer:num-file-read-exceptions"public static final StringNUM_FILE_REMOVAL_EXCEPTIONS"logviewer:num-file-removal-exceptions"public static final StringNUM_LIST_DUMP_EXCEPTIONS"logviewer:num-list-dump-files-exceptions"public static final StringNUM_LIST_LOG_EXCEPTIONS"logviewer:num-search-log-exceptions"public static final StringNUM_READ_DAEMON_LOG_EXCEPTIONS"logviewer:num-read-daemon-log-exceptions"public static final StringNUM_READ_LOG_EXCEPTIONS"logviewer:num-read-log-exceptions"public static final StringNUM_SEARCH_EXCEPTIONS"logviewer:num-search-exceptions"public static final StringNUM_SET_PERMISSION_EXCEPTIONS"logviewer:num-set-permission-exceptions" -
org.apache.storm.daemon.logviewer.utils.WorkerLogs Modifier and Type Constant Field Value public static final StringWORKER_YAML"worker.yaml"
-
org.apache.storm.daemon.ui.UIServer Modifier and Type Constant Field Value public static final StringSTORM_API_URL_PREFIX"/api/v1/"
-
org.apache.storm.daemon.ui.resources.StormApiResource Modifier and Type Constant Field Value public static final StringcallbackParameterName"callback"
-
org.apache.storm.drpc.PrepareRequest Modifier and Type Constant Field Value public static final StringARGS_STREAM"default"public static final StringID_STREAM"id"public static final StringRETURN_STREAM"ret"
-
org.apache.storm.flux.model.TopologySourceDef Modifier and Type Constant Field Value public static final StringDEFAULT_METHOD_NAME"getTopology"
-
org.apache.storm.hbase.security.HBaseSecurityUtil Modifier and Type Constant Field Value public static final StringHBASE_CREDENTIALS"HBASE_CREDENTIALS"public static final StringHBASE_CREDENTIALS_CONFIG_KEYS"hbaseCredentialsConfigKeys"public static final StringHBASE_KEYTAB_FILE_KEY"hbase.keytab.file"public static final StringHBASE_PRINCIPAL_KEY"hbase.kerberos.principal"public static final StringSTORM_KEYTAB_FILE_KEY"storm.keytab.file"public static final StringSTORM_USER_NAME_KEY"storm.kerberos.principal"
-
org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat Modifier and Type Constant Field Value public static final StringDEFAULT_FIELD_DELIMITER","public static final StringDEFAULT_RECORD_DELIMITER"\n"
-
org.apache.storm.hdfs.security.HdfsSecurityUtil Modifier and Type Constant Field Value public static final StringHDFS_CREDENTIALS"HDFS_CREDENTIALS"public static final StringHDFS_CREDENTIALS_CONFIG_KEYS"hdfsCredentialsConfigKeys"public static final StringSTORM_KEYTAB_FILE_KEY"hdfs.keytab.file"public static final StringSTORM_USER_NAME_KEY"hdfs.kerberos.principal"public static final StringTOPOLOGY_HDFS_URI"topology.hdfs.uri"
-
org.apache.storm.hdfs.spout.Configs Modifier and Type Constant Field Value public static final StringARCHIVE_DIR"hdfsspout.archive.dir"public static final StringBAD_DIR"hdfsspout.badfiles.dir"public static final StringCLOCKS_INSYNC"hdfsspout.clocks.insync"public static final StringCOMMIT_FREQ_COUNT"hdfsspout.commit.count"public static final StringCOMMIT_FREQ_SEC"hdfsspout.commit.sec"public static final intDEFAULT_COMMIT_FREQ_COUNT20000public static final intDEFAULT_COMMIT_FREQ_SEC10public static final StringDEFAULT_HDFS_CONFIG_KEY"hdfs.config"public static final StringDEFAULT_LOCK_DIR".lock"public static final intDEFAULT_LOCK_TIMEOUT300public static final intDEFAULT_MAX_OUTSTANDING10000public static final StringHDFS_URI"hdfsspout.hdfs"public static final StringIGNORE_SUFFIX"hdfsspout.ignore.suffix"public static final StringLOCK_DIR"hdfsspout.lock.dir"public static final StringLOCK_TIMEOUT"hdfsspout.lock.timeout.sec"public static final StringMAX_OUTSTANDING"hdfsspout.max.outstanding"public static final StringREADER_TYPE"hdfsspout.reader.type"public static final StringSEQ"seq"public static final StringSOURCE_DIR"hdfsspout.source.dir"public static final StringTEXT"text" -
org.apache.storm.hdfs.spout.DirLock Modifier and Type Constant Field Value public static final StringDIR_LOCK_FILE"DIRLOCK" -
org.apache.storm.hdfs.spout.HdfsSpoutTopology Modifier and Type Constant Field Value public static final StringBOLT_ID"constbolt"public static final StringSPOUT_ID"hdfsspout" -
org.apache.storm.hdfs.spout.HdfsSpoutTopology.ConstBolt Modifier and Type Constant Field Value public static final StringFIELDS"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 StringBUFFER_SIZE"hdfsspout.reader.buffer.bytes" -
org.apache.storm.hdfs.spout.TextFileReader Modifier and Type Constant Field Value public static final StringBUFFER_SIZE"hdfsspout.reader.buffer.bytes"public static final StringCHARSET"hdfsspout.reader.charset"
-
org.apache.storm.hdfs.trident.format.DelimitedRecordFormat Modifier and Type Constant Field Value public static final StringDEFAULT_FIELD_DELIMITER","public static final StringDEFAULT_RECORD_DELIMITER"\n"
-
org.apache.storm.hive.common.HiveOptions Modifier and Type Constant Field Value public static final intDEFAULT_TICK_TUPLE_INTERVAL_SECS15
-
org.apache.storm.hive.security.HiveSecurityUtil Modifier and Type Constant Field Value public static final StringHIVE_CREDENTIALS"HIVE_CREDENTIALS"public static final StringHIVE_CREDENTIALS_CONFIG_KEYS"hiveCredentialsConfigKeys"public static final StringHIVE_KEYTAB_FILE_KEY"hive.keytab.file"public static final StringHIVE_PRINCIPAL_KEY"hive.kerberos.principal"
-
org.apache.storm.jdbc.topology.AbstractUserTopology Modifier and Type Constant Field Value protected static final StringJDBC_CONF"jdbc.conf"protected static final StringSELECT_QUERY"select dept_name from department, user_department where department.dept_id = user_department.dept_id and user_department.user_id = ?"protected static final StringTABLE_NAME"user"
-
org.apache.storm.jms.example.ExampleJmsTopology Modifier and Type Constant Field Value public static final StringANOTHER_BOLT"ANOTHER_BOLT"public static final StringFINAL_BOLT"FINAL_BOLT"public static final StringINTERMEDIATE_BOLT"INTERMEDIATE_BOLT"public static final StringJMS_QUEUE_SPOUT"JMS_QUEUE_SPOUT"public static final StringJMS_TOPIC_BOLT"JMS_TOPIC_BOLT"public static final StringJMS_TOPIC_SPOUT"JMS_TOPIC_SPOUT"
-
org.apache.storm.jms.trident.TridentJmsSpout Modifier and Type Constant Field Value public static final intDEFAULT_BATCH_SIZE1000public static final StringMAX_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 StringTOPIC"topic"
-
org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper<K,V> Modifier and Type Constant Field Value public static final StringBOLT_KEY"key"public static final StringBOLT_MESSAGE"message"
-
org.apache.storm.kafka.spout.KafkaSpout<K,V> Modifier and Type Constant Field Value public static final longTIMER_DELAY_MS500L -
org.apache.storm.kafka.spout.KafkaSpoutConfig<K,V> Modifier and Type Constant Field Value public static final intDEFAULT_MAX_RETRIES2147483647public static final intDEFAULT_MAX_UNCOMMITTED_OFFSETS10000000public static final intDEFAULT_METRICS_TIME_BUCKET_SIZE_SECONDS60public static final longDEFAULT_OFFSET_COMMIT_PERIOD_MS30000L -
org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopics Modifier and Type Constant Field Value public static final StringTOPIC_0"kafka-spout-test"public static final StringTOPIC_1"kafka-spout-test-1"public static final StringTOPIC_2"kafka-spout-test-2"
-
org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig<K,V> Modifier and Type Constant Field Value public static final longDEFAULT_PARTITION_REFRESH_PERIOD_MS2000Lpublic static final longDEFAULT_POLL_TIMEOUT_MS200Lpublic static final longDEFAULT_START_TS0L
-
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutBatchMetadata Modifier and Type Constant Field Value public static final StringFIRST_OFFSET_KEY"firstOffset"public static final StringLAST_OFFSET_KEY"lastOffset"public static final StringTOPOLOGY_ID_KEY"topologyId" -
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutCoordinator<K,V> Modifier and Type Constant Field Value public static final longTIMER_DELAY_MS500L -
org.apache.storm.kafka.spout.trident.TopicPartitionSerializer Modifier and Type Constant Field Value public static final StringTOPIC_PARTITION_PARTITION_KEY"partition"public static final StringTOPIC_PARTITION_TOPIC_KEY"topic"
-
org.apache.storm.loadgen.CaptureLoad Modifier and Type Constant Field Value public static final StringDEFAULT_OUT_DIR"./loadgen/" -
org.apache.storm.loadgen.LoadMetricsServer Modifier and Type Constant Field Value public static final longDEFAULT_REPORT_INTERVAL30Lpublic static final longDEFAULT_WINDOW_INTERVAL30L
-
org.apache.storm.localizer.LocallyCachedBlob Modifier and Type Constant Field Value public static final longNOT_DOWNLOADED_VERSION-1L -
org.apache.storm.localizer.LocallyCachedTopologyBlob Modifier and Type Constant Field Value public static final longLOCAL_MODE_JAR_VERSION1L
-
org.apache.storm.messaging.netty.BackPressureStatus Modifier and Type Constant Field Value public static final shortIDENTIFIER-600 -
org.apache.storm.messaging.netty.SaslMessageToken Modifier and Type Constant Field Value public static final shortIDENTIFIER-500
-
org.apache.storm.metric.EventLoggerBolt Modifier and Type Constant Field Value public static final StringFIELD_COMPONENT_ID"component-id"public static final StringFIELD_MESSAGE_ID"message-id"public static final StringFIELD_TS"ts"public static final StringFIELD_VALUES"values"
-
org.apache.storm.metric.internal.MultiCountStat<T> Modifier and Type Constant Field Value public static final intTEN_MIN_IN_SECONDS600public static final StringTEN_MIN_IN_SECONDS_STR"600"
-
org.apache.storm.metrics2.reporters.CsvStormReporter Modifier and Type Constant Field Value public static final StringCSV_LOG_DIR"csv.log.dir" -
org.apache.storm.metrics2.reporters.GraphiteStormReporter Modifier and Type Constant Field Value public static final StringGRAPHITE_HOST"graphite.host"public static final StringGRAPHITE_PORT"graphite.port"public static final StringGRAPHITE_PREFIXED_WITH"graphite.prefixed.with"public static final StringGRAPHITE_TRANSPORT"graphite.transport" -
org.apache.storm.metrics2.reporters.JmxStormReporter Modifier and Type Constant Field Value public static final StringJMX_DOMAIN"jmx.domain" -
org.apache.storm.metrics2.reporters.StormReporter Modifier and Type Constant Field Value public static final StringREPORT_DIMENSIONS_ENABLED"report.dimensions.enabled"public static final StringREPORT_PERIOD"report.period"public static final StringREPORT_PERIOD_UNITS"report.period.units"
-
org.apache.storm.multilang.JsonSerializer Modifier and Type Constant Field Value public static final StringDEFAULT_CHARSET"UTF-8"
-
org.apache.storm.networktopography.DNSToSwitchMapping Modifier and Type Constant Field Value public static final StringDEFAULT_RACK"/default-rack"
-
org.apache.storm.pacemaker.codec.ThriftNettyClientCodec Modifier and Type Constant Field Value public static final StringKERBEROS_HANDLER"kerberos-handler"public static final StringSASL_HANDLER"sasl-handler" -
org.apache.storm.pacemaker.codec.ThriftNettyServerCodec Modifier and Type Constant Field Value public static final StringKERBEROS_HANDLER"kerberos-handler"public static final StringSASL_HANDLER"sasl-handler"
-
org.apache.storm.perf.ConstSpoutIdBoltNullBoltTopo Modifier and Type Constant Field Value public static final StringBOLT1_COUNT"bolt1.count"public static final StringBOLT1_ID"idBolt"public static final StringBOLT2_COUNT"bolt2.count"public static final StringBOLT2_ID"nullBolt"public static final StringSPOUT_COUNT"spout.count"public static final StringSPOUT_ID"constSpout"public static final StringTOPOLOGY_NAME"ConstSpoutIdBoltNullBoltTopo" -
org.apache.storm.perf.ConstSpoutNullBoltTopo Modifier and Type Constant Field Value public static final StringBOLT_COUNT"bolt.count"public static final StringBOLT_ID"nullBolt"public static final StringDEFAULT_GROUPING"local"public static final StringGROUPING"grouping"public static final StringLOCAL_GROPING"local"public static final StringSHUFFLE_GROUPING"shuffle"public static final StringSPOUT_COUNT"spout.count"public static final StringSPOUT_ID"constSpout"public static final StringTOPOLOGY_NAME"ConstSpoutNullBoltTopo" -
org.apache.storm.perf.ConstSpoutOnlyTopo Modifier and Type Constant Field Value public static final StringSPOUT_ID"constSpout"public static final StringTOPOLOGY_NAME"ConstSpoutOnlyTopo" -
org.apache.storm.perf.FileReadWordCountTopo Modifier and Type Constant Field Value public static final StringCOUNT_ID"counter"public static final StringCOUNT_NUM"counter.count"public static final intDEFAULT_COUNT_BOLT_NUM2public static final intDEFAULT_SPLIT_BOLT_NUM2public static final intDEFAULT_SPOUT_NUM1public static final StringINPUT_FILE"input.file"public static final StringSPLIT_ID"splitter"public static final StringSPLIT_NUM"splitter.count"public static final StringSPOUT_ID"spout"public static final StringSPOUT_NUM"spout.count"public static final StringTOPOLOGY_NAME"FileReadWordCountTopo" -
org.apache.storm.perf.HdfsSpoutNullBoltTopo Modifier and Type Constant Field Value public static final intDEFAULT_BOLT_NUM1public static final intDEFAULT_SPOUT_NUM1 -
org.apache.storm.perf.KafkaClientHdfsTopo Modifier and Type Constant Field Value public static final StringBOLT_ID"hdfsBolt"public static final StringBOLT_NUM"bolt.count"public static final intDEFAULT_BOLT_NUM1public static final intDEFAULT_HDFS_BATCH1000public static final intDEFAULT_SPOUT_NUM1public static final StringHDFS_BATCH"hdfs.batch"public static final StringHDFS_PATH"hdfs.dir"public static final StringHDFS_URI"hdfs.uri"public static final StringKAFKA_BOOTSTRAP_HOSTS"kafka.bootstrap.hosts"public static final StringKAFKA_TOPIC"kafka.topic"public static final StringSPOUT_ID"kafkaSpout"public static final StringSPOUT_NUM"spout.count"public static final StringTOPOLOGY_NAME"KafkaHdfsTopo" -
org.apache.storm.perf.KafkaClientSpoutNullBoltTopo Modifier and Type Constant Field Value public static final StringBOLT_ID"devNullBolt"public static final StringBOLT_NUM"bolt.count"public static final StringBOOTSTRAP_SERVERS"bootstrap.servers"public static final intDEFAULT_BOLT_NUM1public static final intDEFAULT_SPOUT_NUM1public static final StringKAFKA_TOPIC"kafka.topic"public static final StringOFFSET_COMMIT_PERIOD_MS"offset.commit.period.ms"public static final StringPROCESSING_GUARANTEE"processing.guarantee"public static final StringSPOUT_ID"kafkaSpout"public static final StringSPOUT_NUM"spout.count" -
org.apache.storm.perf.SimplifiedWordCountTopo Modifier and Type Constant Field Value public static final StringBOLT_NUM"counter.count"public static final StringCOUNT_ID"counter"public static final intDEFAULT_COUNT_BOLT_NUM1public static final intDEFAULT_SPOUT_NUM1public static final StringINPUT_FILE"input.file"public static final StringSPOUT_ID"spout"public static final StringSPOUT_NUM"spout.count"public static final StringTOPOLOGY_NAME"SimplifiedWordCountTopo" -
org.apache.storm.perf.StrGenSpoutHdfsBoltTopo Modifier and Type Constant Field Value public static final StringBOLT_ID"hdfsBolt"public static final StringBOLT_NUM"bolt.count"public static final intDEFAULT_BOLT_NUM1public static final intDEFAULT_HDFS_BATCH1000public static final intDEFAULT_SPOUT_NUM1public static final StringHDFS_BATCH"hdfs.batch"public static final StringHDFS_PATH"hdfs.dir"public static final StringHDFS_URI"hdfs.uri"public static final StringSPOUT_ID"GenSpout"public static final StringSPOUT_NUM"spout.count"public static final StringTOPOLOGY_NAME"StrGenSpoutHdfsBoltTopo"
-
org.apache.storm.perf.bolt.CountBolt Modifier and Type Constant Field Value public static final StringFIELDS_COUNT"count"public static final StringFIELDS_WORD"word" -
org.apache.storm.perf.bolt.SplitSentenceBolt Modifier and Type Constant Field Value public static final StringFIELDS"word"
-
org.apache.storm.perf.spout.FileReadSpout Modifier and Type Constant Field Value public static final StringFIELDS"sentence" -
org.apache.storm.perf.spout.WordGenSpout Modifier and Type Constant Field Value public static final StringFIELDS"word"
-
org.apache.storm.perf.utils.BasicMetricsCollector Modifier and Type Constant Field Value public static final StringEXECUTORS"executors"public static final StringSPOUT_ACKED"spout_acks"public static final StringSPOUT_AVG_COMPLETE_LATENCY"spout_avg_complete_latency(ms)"public static final StringSPOUT_AVG_LATENCY_FORMAT"%.3f"public static final StringSPOUT_EXECUTORS"spout_executors"public static final StringSPOUT_MAX_COMPLETE_LATENCY"spout_max_complete_latency(ms)"public static final StringSPOUT_MAX_LATENCY_FORMAT"%.3f"public static final StringSPOUT_THROUGHPUT"spout_throughput (acks/s)"public static final StringSPOUT_TRANSFERRED"spout_transferred (messages)"public static final StringTASKS"tasks"public static final StringTIME"elapsed (sec)"public static final StringTIME_FORMAT"%d"public static final StringTOTAL_SLOTS"total_slots"public static final StringTRANSFERRED"transferred (messages)"public static final StringUSED_SLOTS"used_slots"public static final StringWORKERS"workers"public static final StringXSFER_RATE"transfer rate (messages/s)"
-
org.apache.storm.redis.state.RedisKeyValueState<K,V> Modifier and Type Constant Field Value public static final intITERATOR_CHUNK_SIZE100
-
org.apache.storm.scheduler.blacklist.BlacklistScheduler Modifier and Type Constant Field Value public static final intDEFAULT_BLACKLIST_SCHEDULER_RESUME_TIME1800public static final intDEFAULT_BLACKLIST_SCHEDULER_TOLERANCE_COUNT3public static final intDEFAULT_BLACKLIST_SCHEDULER_TOLERANCE_TIME300
-
org.apache.storm.scheduler.blacklist.strategies.DefaultBlacklistStrategy Modifier and Type Constant Field Value public static final intDEFAULT_BLACKLIST_SCHEDULER_RESUME_TIME1800public static final intDEFAULT_BLACKLIST_SCHEDULER_TOLERANCE_COUNT3
-
org.apache.storm.scheduler.resource.strategies.scheduling.ConstraintSolverConfig Modifier and Type Constant Field Value public static final StringCONSTRAINT_TYPE_INCOMPATIBLE_COMPONENTS"incompatibleComponents"public static final StringCONSTRAINT_TYPE_MAX_NODE_CO_LOCATION_CNT"maxNodeCoLocationCnt"
-
org.apache.storm.scheduler.utils.ArtifactoryConfigLoader Modifier and Type Constant Field Value protected static final StringLOCAL_ARTIFACT_DIR"scheduler_artifacts"
-
org.apache.storm.security.auth.AutoSSL Modifier and Type Constant Field Value public static final StringSSL_FILES_CONF"ssl.credential.files" -
org.apache.storm.security.auth.ClientAuthUtils Modifier and Type Constant Field Value public static final StringLOGIN_CONTEXT_CLIENT"StormClient"public static final StringLOGIN_CONTEXT_PACEMAKER_CLIENT"PacemakerClient"public static final StringLOGIN_CONTEXT_PACEMAKER_DIGEST"PacemakerDigest"public static final StringLOGIN_CONTEXT_PACEMAKER_SERVER"PacemakerServer"public static final StringLOGIN_CONTEXT_SERVER"StormServer"public static final StringSERVICE"storm_thrift_server" -
org.apache.storm.security.auth.FixedGroupsMapping Modifier and Type Constant Field Value public static final StringSTORM_FIXED_GROUP_MAPPING"storm.fixed.group.mapping" -
org.apache.storm.security.auth.X509CertPrincipalToLocal Modifier and Type Constant Field Value public static final StringX509_CERT_PRINCIPAL_TO_LOCAL_REGEX"x509.cert.principal.to.local.regex"
-
org.apache.storm.security.auth.authorizer.DRPCAuthorizerBase Modifier and Type Constant Field Value public static final StringFUNCTION_NAME"function.name" -
org.apache.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer Modifier and Type Constant Field Value public static final StringCLIENT_USERS_KEY"client.users"public static final StringFUNCTION_KEY"function.name"public static final StringINVOCATION_USER_KEY"invocation.user" -
org.apache.storm.security.auth.authorizer.ImpersonationAuthorizer Modifier and Type Constant Field Value protected static final StringWILD_CARD"*" -
org.apache.storm.security.auth.authorizer.SimpleWhitelistAuthorizer Modifier and Type Constant Field Value public static final StringWHITELIST_USERS_CONF"storm.auth.simple-white-list.users"
-
org.apache.storm.security.auth.digest.DigestSaslTransportPlugin Modifier and Type Constant Field Value public static final StringDIGEST"DIGEST-MD5" -
org.apache.storm.security.auth.digest.JassPasswordProvider Modifier and Type Constant Field Value public static final StringSYSPROP_SUPER_PASSWORD"storm.SASLAuthenticationProvider.superPassword"
-
org.apache.storm.security.auth.kerberos.KerberosSaslTransportPlugin Modifier and Type Constant Field Value public static final StringKERBEROS"GSSAPI" -
org.apache.storm.security.auth.kerberos.NoOpTTrasport Modifier and Type Constant Field Value protected static final intDEFAULT_MAX_LENGTH2147483647protected static final intMECHANISM_NAME_BYTES1protected static final intPAYLOAD_LENGTH_BYTES4protected static final intSTATUS_BYTES1
-
org.apache.storm.security.auth.plain.PlainSaslTransportPlugin Modifier and Type Constant Field Value public static final StringPLAIN"PLAIN" -
org.apache.storm.security.auth.plain.SaslPlainServer.SecurityProvider Modifier and Type Constant Field Value public static final StringSASL_PLAIN_SERVER"SaslPlainServer"
-
org.apache.storm.security.serialization.BlowfishTupleSerializer Modifier and Type Constant Field Value public static final StringSECRET_KEY"topology.tuple.serializer.blowfish.key"
-
org.apache.storm.spout.CheckpointSpout Modifier and Type Constant Field Value public static final StringCHECKPOINT_COMPONENT_ID"$checkpointspout"public static final StringCHECKPOINT_FIELD_ACTION"action"public static final StringCHECKPOINT_FIELD_TXID"txid"public static final StringCHECKPOINT_STREAM_ID"$checkpoint"
-
org.apache.storm.sql.parser.StormParser Modifier and Type Constant Field Value public static final intDEFAULT_IDENTIFIER_MAX_LENGTH128
-
org.apache.storm.sql.parser.impl.SimpleCharStream Modifier and Type Constant Field Value public static final booleanstaticFlagfalse -
org.apache.storm.sql.parser.impl.StormParserImplConstants Modifier and Type Constant Field Value public static final intA1public static final intABS2public static final intABSOLUTE3public static final intACTION4public static final intADA5public static final intADD6public static final intADMIN7public static final intAFTER8public static final intALL9public static final intALLOCATE10public static final intALLOW11public static final intALTER12public static final intALWAYS13public static final intAND14public static final intANY15public static final intAPPLY16public static final intAPPROX_NUMERIC_LITERAL649public static final intARE17public static final intARRAY18public static final intARRAY_MAX_CARDINALITY19public static final intAS20public static final intASC21public static final intASENSITIVE22public static final intASSERTION23public static final intASSIGNMENT24public static final intASYMMETRIC25public static final intAT26public static final intATOMIC27public static final intATTRIBUTE28public static final intATTRIBUTES29public static final intAUTHORIZATION30public static final intAVG31public static final intBACK_QUOTED_IDENTIFIER708public static final intBEFORE32public static final intBEGIN33public static final intBEGIN_FRAME34public static final intBEGIN_PARTITION35public static final intBEL714public static final intBERNOULLI36public static final intBETWEEN37public static final intBIGINT38public static final intBINARY39public static final intBINARY_STRING_LITERAL654public static final intBIT40public static final intBLOB41public static final intBOOLEAN42public static final intBOTH43public static final intBRACKET_QUOTED_IDENTIFIER706public static final intBREADTH44public static final intBTID2public static final intBY45public static final intC46public static final intCALL47public static final intCALLED48public static final intCARDINALITY49public static final intCARET693public static final intCASCADE50public static final intCASCADED51public static final intCASE52public static final intCAST53public static final intCATALOG54public static final intCATALOG_NAME55public static final intCEIL56public static final intCEILING57public static final intCENTURY58public static final intCHAIN59public static final intCHAR60public static final intCHAR_LENGTH61public static final intCHARACTER62public static final intCHARACTER_LENGTH63public static final intCHARACTER_SET_CATALOG64public static final intCHARACTER_SET_NAME65public static final intCHARACTER_SET_SCHEMA66public static final intCHARACTERISTICS67public static final intCHARACTERS68public static final intCHARSETNAME658public static final intCHECK69public static final intCLASS_ORIGIN71public static final intCLASSIFIER70public static final intCLOB72public static final intCLOSE73public static final intCOALESCE74public static final intCOBOL75public static final intCOLLATE76public static final intCOLLATION77public static final intCOLLATION_CATALOG78public static final intCOLLATION_ID709public static final intCOLLATION_NAME79public static final intCOLLATION_SCHEMA80public static final intCOLLECT81public static final intCOLON677public static final intCOLUMN82public static final intCOLUMN_NAME83public static final intCOMMA672public static final intCOMMAND_FUNCTION84public static final intCOMMAND_FUNCTION_CODE85public static final intCOMMIT86public static final intCOMMITTED87public static final intCONCAT687public static final intCONDITION88public static final intCONDITION_NUMBER89public static final intCONNECT90public static final intCONNECTION91public static final intCONNECTION_NAME92public static final intCONSTRAINT93public static final intCONSTRAINT_CATALOG94public static final intCONSTRAINT_NAME95public static final intCONSTRAINT_SCHEMA96public static final intCONSTRAINTS97public static final intCONSTRUCTOR98public static final intCONTAINS99public static final intCONTINUE100public static final intCONVERT101public static final intCORR102public static final intCORRESPONDING103public static final intCOUNT104public static final intCOVAR_POP105public static final intCOVAR_SAMP106public static final intCREATE107public static final intCROSS108public static final intCUBE109public static final intCUME_DIST110public static final intCURRENT111public static final intCURRENT_CATALOG112public static final intCURRENT_DATE113public static final intCURRENT_DEFAULT_TRANSFORM_GROUP114public static final intCURRENT_PATH115public static final intCURRENT_ROLE116public static final intCURRENT_ROW117public static final intCURRENT_SCHEMA118public static final intCURRENT_TIME119public static final intCURRENT_TIMESTAMP120public static final intCURRENT_TRANSFORM_GROUP_FOR_TYPE121public static final intCURRENT_USER122public static final intCURSOR123public static final intCURSOR_NAME124public static final intCYCLE125public static final intDATA126public static final intDATABASE127public static final intDATE128public static final intDATETIME_INTERVAL_CODE129public static final intDATETIME_INTERVAL_PRECISION130public static final intDAY131public static final intDEALLOCATE132public static final intDEC133public static final intDECADE134public static final intDECIMAL135public static final intDECIMAL_NUMERIC_LITERAL650public static final intDECLARE136public static final intDEFAULT0public static final intDEFAULT_137public static final intDEFAULTS138public static final intDEFERRABLE139public static final intDEFERRED140public static final intDEFINE141public static final intDEFINED142public static final intDEFINER143public static final intDEGREE144public static final intDELETE145public static final intDENSE_RANK146public static final intDEPTH147public static final intDEREF148public static final intDERIVED149public static final intDESC150public static final intDESCRIBE151public static final intDESCRIPTION152public static final intDESCRIPTOR153public static final intDETERMINISTIC154public static final intDIAGNOSTICS155public static final intDIGIT713public static final intDISALLOW156public static final intDISCONNECT157public static final intDISPATCH158public static final intDISTINCT159public static final intDOLLAR694public static final intDOMAIN160public static final intDOT671public static final intDOUBLE161public static final intDOUBLE_PERIOD689public static final intDOUBLE_QUOTE691public static final intDOW162public static final intDOY163public static final intDQID1public static final intDROP164public static final intDYNAMIC165public static final intDYNAMIC_FUNCTION166public static final intDYNAMIC_FUNCTION_CODE167public static final intEACH168public static final intELEMENT169public static final intELSE170public static final intEMPTY171public static final intEND172public static final intEND_EXEC173public static final intEND_FRAME174public static final intEND_PARTITION175public static final intEOF0public static final intEPOCH176public static final intEQ673public static final intEQUALS177public static final intESCAPE178public static final intEVERY179public static final intEXCEPT180public static final intEXCEPTION181public static final intEXCLUDE182public static final intEXCLUDING183public static final intEXEC184public static final intEXECUTE185public static final intEXISTS186public static final intEXP187public static final intEXPLAIN188public static final intEXPONENT651public static final intEXTEND189public static final intEXTERNAL190public static final intEXTRACT191public static final intFALSE192public static final intFETCH193public static final intFILTER194public static final intFINAL195public static final intFIRST196public static final intFIRST_VALUE197public static final intFLOAT198public static final intFLOOR199public static final intFOLLOWING200public static final intFOR201public static final intFOREIGN202public static final intFORMAL_COMMENT703public static final intFORTRAN203public static final intFOUND204public static final intFRAC_SECOND205public static final intFRAME_ROW206public static final intFREE207public static final intFROM208public static final intFULL209public static final intFUNCTION210public static final intFUSION211public static final intG212public static final intGE679public static final intGENERAL213public static final intGENERATED214public static final intGEOMETRY215public static final intGET216public static final intGLOBAL217public static final intGO218public static final intGOTO219public static final intGRANT220public static final intGRANTED221public static final intGROUP222public static final intGROUPING223public static final intGROUPS224public static final intGT674public static final intHAVING225public static final intHEXDIGIT652public static final intHIERARCHY226public static final intHOLD227public static final intHOOK676public static final intHOUR228public static final intIDENTIFIER710public static final intIDENTITY229public static final intIMMEDIATE230public static final intIMMEDIATELY231public static final intIMPLEMENTATION232public static final intIMPORT233public static final intIN234public static final intIN_FORMAL_COMMENT3public static final intIN_MULTI_LINE_COMMENT4public static final intINCLUDING235public static final intINCREMENT236public static final intINDICATOR237public static final intINITIAL238public static final intINITIALLY239public static final intINNER240public static final intINOUT241public static final intINPUT242public static final intINPUTFORMAT642public static final intINSENSITIVE243public static final intINSERT244public static final intINSTANCE245public static final intINSTANTIABLE246public static final intINT247public static final intINTEGER248public static final intINTERSECT249public static final intINTERSECTION250public static final intINTERVAL251public static final intINTO252public static final intINVOKER253public static final intIS254public static final intISOLATION255public static final intJAR647public static final intJAVA256public static final intJOIN257public static final intJSON258public static final intK259public static final intKEY260public static final intKEY_MEMBER261public static final intKEY_TYPE262public static final intLABEL263public static final intLAG264public static final intLANGUAGE265public static final intLARGE266public static final intLAST267public static final intLAST_VALUE268public static final intLATERAL269public static final intLBRACE666public static final intLBRACE_D662public static final intLBRACE_FN665public static final intLBRACE_T663public static final intLBRACE_TS664public static final intLBRACKET668public static final intLE678public static final intLEAD270public static final intLEADING271public static final intLEFT272public static final intLENGTH273public static final intLETTER712public static final intLEVEL274public static final intLIBRARY275public static final intLIKE276public static final intLIKE_REGEX277public static final intLIMIT278public static final intLN279public static final intLOCAL280public static final intLOCALTIME281public static final intLOCALTIMESTAMP282public static final intLOCATION641public static final intLOCATOR283public static final intLOWER284public static final intLPAREN660public static final intLT675public static final intM285public static final intMAP286public static final intMATCH287public static final intMATCH_NUMBER290public static final intMATCH_RECOGNIZE291public static final intMATCHED288public static final intMATCHES289public static final intMAX292public static final intMAXVALUE293public static final intMEASURES294public static final intMEMBER295public static final intMERGE296public static final intMESSAGE_LENGTH297public static final intMESSAGE_OCTET_LENGTH298public static final intMESSAGE_TEXT299public static final intMETHOD300public static final intMICROSECOND301public static final intMILLENNIUM302public static final intMIN303public static final intMINUS683public static final intMINUTE304public static final intMINVALUE305public static final intMOD306public static final intMODIFIES307public static final intMODULE308public static final intMONTH309public static final intMORE_310public static final intMULTI_LINE_COMMENT704public static final intMULTISET311public static final intMUMPS312public static final intNAME313public static final intNAMED_ARGUMENT_ASSIGNMENT688public static final intNAMES314public static final intNATIONAL315public static final intNATURAL316public static final intNCHAR317public static final intNCLOB318public static final intNE680public static final intNE2681public static final intNESTING319public static final intNEW320public static final intNEXT321public static final intNO322public static final intNONE323public static final intNORMALIZE324public static final intNORMALIZED325public static final intNOT326public static final intNTH_VALUE327public static final intNTILE328public static final intNULL329public static final intNULLABLE330public static final intNULLIF331public static final intNULLS332public static final intNUMBER333public static final intNUMERIC334public static final intOBJECT335public static final intOCCURRENCES_REGEX336public static final intOCTET_LENGTH337public static final intOCTETS338public static final intOF339public static final intOFFSET340public static final intOLD341public static final intOMIT342public static final intON343public static final intONE344public static final intONLY345public static final intOPEN346public static final intOPTION347public static final intOPTIONS348public static final intOR349public static final intORDER350public static final intORDERING351public static final intORDINALITY352public static final intOTHERS353public static final intOUT354public static final intOUTER355public static final intOUTPUT356public static final intOUTPUTFORMAT643public static final intOVER357public static final intOVERLAPS358public static final intOVERLAY359public static final intOVERRIDING360public static final intPAD361public static final intPARALLELISM644public static final intPARAMETER362public static final intPARAMETER_MODE363public static final intPARAMETER_NAME364public static final intPARAMETER_ORDINAL_POSITION365public static final intPARAMETER_SPECIFIC_CATALOG366public static final intPARAMETER_SPECIFIC_NAME367public static final intPARAMETER_SPECIFIC_SCHEMA368public static final intPARTIAL369public static final intPARTITION370public static final intPASCAL371public static final intPASSTHROUGH372public static final intPAST373public static final intPATH374public static final intPATTERN375public static final intPER376public static final intPERCENT377public static final intPERCENT_RANK380public static final intPERCENT_REMAINDER686public static final intPERCENTILE_CONT378public static final intPERCENTILE_DISC379public static final intPERIOD381public static final intPERMUTE382public static final intPLACING383public static final intPLAN384public static final intPLI385public static final intPLUS682public static final intPORTION386public static final intPOSITION387public static final intPOSITION_REGEX388public static final intPOWER389public static final intPRECEDES390public static final intPRECEDING391public static final intPRECISION392public static final intPREFIXED_STRING_LITERAL656public static final intPREPARE393public static final intPRESERVE394public static final intPREV395public static final intPRIMARY396public static final intPRIOR397public static final intPRIVILEGES398public static final intPROCEDURE399public static final intPUBLIC400public static final intQUARTER401public static final intQUOTE690public static final intQUOTED_IDENTIFIER707public static final intQUOTED_STRING655public static final intRANGE402public static final intRANK403public static final intRBRACE667public static final intRBRACKET669public static final intREAD404public static final intREADS405public static final intREAL406public static final intRECURSIVE407public static final intREF408public static final intREFERENCES409public static final intREFERENCING410public static final intREGR_AVGX411public static final intREGR_AVGY412public static final intREGR_COUNT413public static final intREGR_INTERCEPT414public static final intREGR_R2415public static final intREGR_SLOPE416public static final intREGR_SXX417public static final intREGR_SXY418public static final intREGR_SYY419public static final intRELATIVE420public static final intRELEASE421public static final intREPEATABLE422public static final intREPLACE423public static final intRESET424public static final intRESTART425public static final intRESTRICT426public static final intRESULT427public static final intRETURN428public static final intRETURNED_CARDINALITY429public static final intRETURNED_LENGTH430public static final intRETURNED_OCTET_LENGTH431public static final intRETURNED_SQLSTATE432public static final intRETURNS433public static final intREVOKE434public static final intRIGHT435public static final intROLE436public static final intROLLBACK437public static final intROLLUP438public static final intROUTINE439public static final intROUTINE_CATALOG440public static final intROUTINE_NAME441public static final intROUTINE_SCHEMA442public static final intROW443public static final intROW_COUNT444public static final intROW_NUMBER445public static final intROWS446public static final intRPAREN661public static final intRUNNING447public static final intSAVEPOINT448public static final intSCALE449public static final intSCHEMA450public static final intSCHEMA_NAME451public static final intSCOPE452public static final intSCOPE_CATALOGS453public static final intSCOPE_NAME454public static final intSCOPE_SCHEMA455public static final intSCROLL456public static final intSEARCH457public static final intSECOND458public static final intSECTION459public static final intSECURITY460public static final intSEEK461public static final intSELECT462public static final intSELF463public static final intSEMICOLON670public static final intSENSITIVE464public static final intSEQUENCE465public static final intSERIALIZABLE466public static final intSERVER467public static final intSERVER_NAME468public static final intSESSION469public static final intSESSION_USER470public static final intSET471public static final intSET_MINUS473public static final intSETS472public static final intSHOW474public static final intSIMILAR475public static final intSIMPLE476public static final intSINGLE_LINE_COMMENT702public static final intSIZE477public static final intSKIP_478public static final intSLASH685public static final intSMALLINT479public static final intSOME480public static final intSOURCE481public static final intSPACE482public static final intSPECIFIC483public static final intSPECIFIC_NAME484public static final intSPECIFICTYPE485public static final intSQL486public static final intSQL_BIGINT490public static final intSQL_BINARY491public static final intSQL_BIT492public static final intSQL_BLOB493public static final intSQL_BOOLEAN494public static final intSQL_CHAR495public static final intSQL_CLOB496public static final intSQL_DATE497public static final intSQL_DECIMAL498public static final intSQL_DOUBLE499public static final intSQL_FLOAT500public static final intSQL_INTEGER501public static final intSQL_INTERVAL_DAY502public static final intSQL_INTERVAL_DAY_TO_HOUR503public static final intSQL_INTERVAL_DAY_TO_MINUTE504public static final intSQL_INTERVAL_DAY_TO_SECOND505public static final intSQL_INTERVAL_HOUR506public static final intSQL_INTERVAL_HOUR_TO_MINUTE507public static final intSQL_INTERVAL_HOUR_TO_SECOND508public static final intSQL_INTERVAL_MINUTE509public static final intSQL_INTERVAL_MINUTE_TO_SECOND510public static final intSQL_INTERVAL_MONTH511public static final intSQL_INTERVAL_SECOND512public static final intSQL_INTERVAL_YEAR513public static final intSQL_INTERVAL_YEAR_TO_MONTH514public static final intSQL_LONGVARBINARY515public static final intSQL_LONGVARCHAR516public static final intSQL_LONGVARNCHAR517public static final intSQL_NCHAR518public static final intSQL_NCLOB519public static final intSQL_NUMERIC520public static final intSQL_NVARCHAR521public static final intSQL_REAL522public static final intSQL_SMALLINT523public static final intSQL_TIME524public static final intSQL_TIMESTAMP525public static final intSQL_TINYINT526public static final intSQL_TSI_DAY527public static final intSQL_TSI_FRAC_SECOND528public static final intSQL_TSI_HOUR529public static final intSQL_TSI_MICROSECOND530public static final intSQL_TSI_MINUTE531public static final intSQL_TSI_MONTH532public static final intSQL_TSI_QUARTER533public static final intSQL_TSI_SECOND534public static final intSQL_TSI_WEEK535public static final intSQL_TSI_YEAR536public static final intSQL_VARBINARY537public static final intSQL_VARCHAR538public static final intSQLEXCEPTION487public static final intSQLSTATE488public static final intSQLWARNING489public static final intSQRT539public static final intSTAR684public static final intSTART540public static final intSTATE541public static final intSTATEMENT542public static final intSTATIC543public static final intSTDDEV_POP544public static final intSTDDEV_SAMP545public static final intSTORED645public static final intSTREAM546public static final intSTRUCTURE547public static final intSTYLE548public static final intSUBCLASS_ORIGIN549public static final intSUBMULTISET550public static final intSUBSET551public static final intSUBSTITUTE552public static final intSUBSTRING553public static final intSUBSTRING_REGEX554public static final intSUCCEEDS555public static final intSUM556public static final intSYMMETRIC557public static final intSYSTEM558public static final intSYSTEM_TIME559public static final intSYSTEM_USER560public static final intTABLE561public static final intTABLE_NAME562public static final intTABLESAMPLE563public static final intTBLPROPERTIES646public static final intTEMPORARY564public static final intTHEN565public static final intTIES566public static final intTIME567public static final intTIMESTAMP568public static final intTIMESTAMPADD569public static final intTIMESTAMPDIFF570public static final intTIMEZONE_HOUR571public static final intTIMEZONE_MINUTE572public static final intTINYINT573public static final intTO574public static final intTOP_LEVEL_COUNT575public static final intTRAILING576public static final intTRANSACTION577public static final intTRANSACTIONS_ACTIVE578public static final intTRANSACTIONS_COMMITTED579public static final intTRANSACTIONS_ROLLED_BACK580public static final intTRANSFORM581public static final intTRANSFORMS582public static final intTRANSLATE583public static final intTRANSLATE_REGEX584public static final intTRANSLATION585public static final intTREAT586public static final intTRIGGER587public static final intTRIGGER_CATALOG588public static final intTRIGGER_NAME589public static final intTRIGGER_SCHEMA590public static final intTRIM591public static final intTRIM_ARRAY592public static final intTRUE593public static final intTRUNCATE594public static final intTYPE595public static final intUESCAPE596public static final intUNBOUNDED597public static final intUNCOMMITTED598public static final intUNDER599public static final intUNICODE_QUOTED_ESCAPE_CHAR659public static final intUNICODE_QUOTED_IDENTIFIER711public static final intUNICODE_STRING_LITERAL657public static final intUNION600public static final intUNIQUE601public static final intUNKNOWN602public static final intUNNAMED603public static final intUNNEST604public static final intUNSIGNED_INTEGER_LITERAL648public static final intUPDATE605public static final intUPPER606public static final intUPSERT607public static final intUSAGE608public static final intUSER609public static final intUSER_DEFINED_TYPE_CATALOG610public static final intUSER_DEFINED_TYPE_CODE611public static final intUSER_DEFINED_TYPE_NAME612public static final intUSER_DEFINED_TYPE_SCHEMA613public static final intUSING614public static final intVALUE615public static final intVALUE_OF617public static final intVALUES616public static final intVAR_POP618public static final intVAR_SAMP619public static final intVARBINARY620public static final intVARCHAR621public static final intVARYING622public static final intVERSION623public static final intVERSIONING624public static final intVERTICAL_BAR692public static final intVIEW625public static final intWEEK626public static final intWHEN627public static final intWHENEVER628public static final intWHERE629public static final intWHITESPACE653public static final intWIDTH_BUCKET630public static final intWINDOW631public static final intWITH632public static final intWITHIN633public static final intWITHOUT634public static final intWORK635public static final intWRAPPER636public static final intWRITE637public static final intXML638public static final intYEAR639public static final intZONE640 -
org.apache.storm.sql.parser.impl.TokenMgrError Modifier and Type Constant Field Value public static final intINVALID_LEXICAL_STATE2public static final intLEXICAL_ERROR0public static final intLOOP_DETECTED3public static final intSTATIC_LEXER_ERROR1
-
org.apache.storm.sql.planner.streams.QueryPlanner Modifier and Type Constant Field Value public static final intSTORM_REL_CONVERSION_RULES1
-
org.apache.storm.sql.planner.streams.rules.StreamsScanRule Modifier and Type Constant Field Value public static final intDEFAULT_PARALLELISM_HINT1
-
org.apache.storm.st.topology.TestableTopology Modifier and Type Constant Field Value public static final StringDUMMY_FIELD"dummy"public static final intTIMEDATA_SLEEP_BETWEEN_EMITS_MS20
-
org.apache.storm.st.topology.window.IncrementingSpout Modifier and Type Constant Field Value public static final StringNUMBER_FIELD"number"
-
org.apache.storm.stats.ClientStatsUtil Modifier and Type Constant Field Value public static final StringBOLT"bolt"public static final StringSPOUT"spout"public static final StringTIME_SECS"time-secs" -
org.apache.storm.stats.StatsUtil Modifier and Type Constant Field Value public static final intTEN_MIN_IN_SECONDS600public static final StringTEN_MIN_IN_SECONDS_STR"600"public static final StringTYPE"type"
-
org.apache.storm.streams.WindowNode Modifier and Type Constant Field Value public static final StringPUNCTUATION"__punctuation"
-
org.apache.storm.submit.command.DependencyResolverMain Modifier and Type Constant Field Value public static final StringDEFAULT_FAILBACK_MAVEN_LOCAL_REPOSITORY_DIRECTORY"local-repo"
-
org.apache.storm.task.ShellBolt Modifier and Type Constant Field Value public static final StringHEARTBEAT_STREAM_ID"__heartbeat" -
org.apache.storm.task.WorkerTopologyContext Modifier and Type Constant Field Value public static final StringSHARED_EXECUTOR"executor"
-
org.apache.storm.topology.WindowedBoltExecutor Modifier and Type Constant Field Value public static final StringLATE_TUPLE_FIELD"late_tuple"
-
org.apache.storm.trident.spout.RichSpoutBatchExecutor Modifier and Type Constant Field Value public static final StringMAX_BATCH_SIZE_CONF"topology.spout.max.batch.size" -
org.apache.storm.trident.spout.TridentSpoutExecutor Modifier and Type Constant Field Value public static final StringID_FIELD"$tx"
-
org.apache.storm.trident.topology.MasterBatchCoordinator Modifier and Type Constant Field Value public static final StringBATCH_STREAM_ID"$batch"public static final StringCOMMIT_STREAM_ID"$commit"public static final longINIT_TXID1Lpublic static final StringSUCCESS_STREAM_ID"$success" -
org.apache.storm.trident.topology.TridentBoltExecutor Modifier and Type Constant Field Value public static final StringCOORD_STREAM_PREFIX"$coord-"
-
org.apache.storm.trident.windowing.WindowsStore Modifier and Type Constant Field Value public static final StringKEY_SEPARATOR"|" -
org.apache.storm.trident.windowing.WindowTridentProcessor Modifier and Type Constant Field Value public static final longDEFAULT_INMEMORY_TUPLE_CACHE_LIMIT100Lpublic static final StringTRIGGER_COUNT_PREFIX"tc|"public static final StringTRIGGER_FIELD_NAME"_task_info"public static final StringTRIGGER_INPROCESS_PREFIX"tip|"public static final StringTRIGGER_PREFIX"tr|"
-
org.apache.storm.tuple.AddressedTuple Modifier and Type Constant Field Value public static final intBROADCAST_DEST-2
-
org.apache.storm.utils.ConfigUtils Modifier and Type Constant Field Value public static final StringRESOURCES_SUBDIR"resources"public static final StringSTORM_HOME"storm.home" -
org.apache.storm.utils.LocalState Modifier and Type Constant Field Value public static final StringLS_APPROVED_WORKERS"approved-workers"public static final StringLS_ID"supervisor-id"public static final StringLS_LOCAL_ASSIGNMENTS"local-assignments"public static final StringLS_TOPO_HISTORY"topo-hist"public static final StringLS_WORKER_HEARTBEAT"worker-heartbeat" -
org.apache.storm.utils.ServerConfigUtils Modifier and Type Constant Field Value public static final StringNIMBUS_DO_NOT_REASSIGN"NIMBUS-DO-NOT-REASSIGN"public static final StringRESOURCES_SUBDIR"resources" -
org.apache.storm.utils.ServerUtils Modifier and Type Constant Field Value public static final intSIGKILL9public static final intSIGTERM15 -
org.apache.storm.utils.Utils Modifier and Type Constant Field Value public static final StringDEFAULT_STREAM_ID"default"
-
org.apache.storm.validation.ConfigValidation.RasConstraintsTypeValidator Modifier and Type Constant Field Value public static final StringCONSTRAINT_TYPE_INCOMPATIBLE_COMPONENTS"incompatibleComponents"public static final StringCONSTRAINT_TYPE_MAX_NODE_CO_LOCATION_CNT"maxNodeCoLocationCnt"
-
org.apache.storm.windowing.WindowManager<T> Modifier and Type Constant Field Value public static final intEXPIRE_EVENTS_THRESHOLD100
-
org.apache.storm.windowing.persistence.WindowState<T> Modifier and Type Constant Field Value public static final intMAX_PARTITION_EVENTS1000public static final intMIN_PARTITIONS10