Uses of Class
org.apache.storm.validation.ConfigValidationAnnotations.isPositiveNumber

Packages that use ConfigValidationAnnotations.isPositiveNumber

Package	Description
org.apache.storm

Uses of ConfigValidationAnnotations.isPositiveNumber in org.apache.storm

Fields in org.apache.storm with annotations of type ConfigValidationAnnotations.isPositiveNumber

Modifier and Type	Field and Description
static String	Config.BACKPRESSURE_DISRUPTOR_HIGH_WATERMARK This signifies the tuple congestion in a disruptor queue.
static String	Config.BACKPRESSURE_DISRUPTOR_LOW_WATERMARK This signifies a state that a disruptor queue has left the congestion.
static String	Config.BACKPRESSURE_ZNODE_TIMEOUT_SECS How long until the backpressure znode is invalid.
static String	Config.BACKPRESSURE_ZNODE_UPDATE_FREQ_SECS How often will the data (timestamp) of backpressure znode be updated.
static String	Config.DRPC_INVOCATIONS_PORT This port on Storm DRPC is used by DRPC topologies to receive function invocations and send results back.
static String	Config.DRPC_INVOCATIONS_THREADS DRPC invocations thrift server worker threads
static String	Config.DRPC_MAX_BUFFER_SIZE Deprecated. As SimpleTrasportPlugin is deprecated, no other thrift transport plugin uses this configuration.
static String	Config.DRPC_PORT This port is used by Storm DRPC for receiving DPRC requests from clients.
static String	Config.DRPC_QUEUE_SIZE DRPC thrift server queue size
static String	Config.DRPC_REQUEST_TIMEOUT_SECS The timeout on DRPC requests within the DRPC server.
static String	Config.DRPC_WORKER_THREADS DRPC thrift server worker threads
static String	Config.LOGVIEWER_CLEANUP_AGE_MINS How many minutes since a log was last modified for the log to be considered for clean-up
static String	Config.LOGVIEWER_CLEANUP_INTERVAL_SECS How often to clean up old log files
static String	Config.LOGVIEWER_HTTPS_PORT Storm Logviewer HTTPS port
static String	Config.LOGVIEWER_MAX_PER_WORKER_LOGS_SIZE_MB The maximum number of bytes per worker’s files can take up in MB
static String	Config.LOGVIEWER_MAX_SUM_WORKER_LOGS_SIZE_MB The maximum number of bytes all worker log files can take up in MB
static String	Config.LOGVIEWER_PORT HTTP UI port for log viewer
static String	Config.NIMBUS_BLOBSTORE_EXPIRATION_SECS During operations with the blob store, via master, how long a connection is idle before nimbus considers it dead and drops the session and any associated connections.
static String	Config.NIMBUS_CLEANUP_INBOX_FREQ_SECS How often nimbus should wake the cleanup thread to clean the inbox.
static String	Config.NIMBUS_CREDENTIAL_RENEW_FREQ_SECS How often nimbus should wake up to renew credentials if needed.
static String	Config.NIMBUS_EXECUTORS_PER_TOPOLOGY A number representing the maximum number of executors any single topology can acquire.
static String	Config.NIMBUS_MONITOR_FREQ_SECS How often nimbus should wake up to check heartbeats and do reassignments.
static String	Config.NIMBUS_QUEUE_SIZE Nimbus thrift server queue size, default is 100000.
static String	Config.NIMBUS_SLOTS_PER_TOPOLOGY A number representing the maximum number of workers any single topology can acquire.
static String	Config.NIMBUS_SUPERVISOR_TIMEOUT_SECS How long before a supervisor can go without heartbeating before nimbus considers it dead and stops assigning new work to it.
static String	Config.NIMBUS_TASK_LAUNCH_SECS A special timeout used when a task is initially launched.
static String	Config.NIMBUS_TASK_TIMEOUT_SECS How long without heartbeating a task can go before nimbus will consider the task dead and reassign it to another location.
static String	Config.NIMBUS_THRIFT_MAX_BUFFER_SIZE Deprecated. As SimpleTrasportPlugin is deprecated, no other thrift transport plugin uses this configuration.
static String	Config.NIMBUS_THRIFT_PORT Which port the Thrift interface of Nimbus should run on.
static String	Config.NIMBUS_THRIFT_THREADS The number of threads that should be used by the nimbus thrift server.
static String	Config.PACEMAKER_MAX_THREADS The maximum number of threads that should be used by the Pacemaker.
static String	Config.PACEMAKER_PORT The port Pacemaker should run on.
static String	Config.STORM_BLOBSTORE_INPUTSTREAM_BUFFER_SIZE_BYTES What buffer size to use for the blobstore uploads.
static String	Config.STORM_BLOBSTORE_REPLICATION_FACTOR Set replication factor for a blob in HDFS Blobstore Implementation
static String	Config.STORM_CLUSTER_METRICS_CONSUMER_PUBLISH_INTERVAL_SECS How often cluster metrics data is published to metrics consumer.
static String	Config.STORM_EXHIBITOR_PORT The port Storm will use to connect to each of the exhibitor servers.
static String	Config.STORM_MESSAGING_NETTY_BUFFER_SIZE Netty based messaging: The buffer size for send/recv buffer
static String	Config.STORM_MESSAGING_NETTY_MAX_SLEEP_MS Netty based messaging: The max # of milliseconds that a peer will wait.
static String	Config.STORM_MESSAGING_NETTY_MIN_SLEEP_MS Netty based messaging: The min # of milliseconds that a peer will wait.
static String	Config.STORM_MESSAGING_NETTY_SERVER_WORKER_THREADS Netty based messaging: The # of worker threads for the server.
static String	Config.STORM_MESSAGING_NETTY_SOCKET_BACKLOG Netty based messaging: Sets the backlog value to specify when the channel binds to a local address
static String	Config.STORM_ZOOKEEPER_PORT The port Storm will use to connect to each of the ZooKeeper servers.
static String	Config.SUPERVISOR_BLOBSTORE_DOWNLOAD_MAX_RETRIES Maximum number of retries a supervisor is allowed to make for downloading a blob.
static String	Config.SUPERVISOR_BLOBSTORE_DOWNLOAD_THREAD_COUNT What blobstore download parallelism the supervisor should use.
static String	Config.SUPERVISOR_CPU_CAPACITY The total amount of CPU resources a supervisor is allowed to give to its workers.
static String	Config.SUPERVISOR_LOCALIZER_CACHE_CLEANUP_INTERVAL_MS The distributed cache cleanup interval.
static String	Config.SUPERVISOR_LOCALIZER_CACHE_TARGET_SIZE_MB The distributed cache target size in MB.
static String	Config.SUPERVISOR_MEMORY_CAPACITY_MB The total amount of memory (in MiB) a supervisor is allowed to give to its workers.
static String	Config.SUPERVISOR_MONITOR_FREQUENCY_SECS How often the supervisor checks the worker heartbeats to see if any of them need to be restarted.
static String	Config.SUPERVISOR_WORKER_SHUTDOWN_SLEEP_SECS How many seconds to sleep for before shutting down threads on worker
static String	Config.SUPERVISOR_WORKER_START_TIMEOUT_SECS How long a worker can go without heartbeating during the initial launch before the supervisor tries to restart the worker process.
static String	Config.SUPERVISOR_WORKER_TIMEOUT_SECS How long a worker can go without heartbeating before the supervisor tries to restart the worker process.
static String	Config.TASK_BACKPRESSURE_POLL_SECS How often to poll for changed topology backpressure flag from ZK
static String	Config.TASK_CREDENTIALS_POLL_SECS How often a task should sync credentials, worst case.
static String	Config.TASK_HEARTBEAT_FREQUENCY_SECS How often a task should heartbeat its status to the master.
static String	Config.TASK_REFRESH_POLL_SECS How often a task should sync its connections with other tasks (if a task is reassigned, the other tasks sending messages to it need to refresh their connections).
static String	Config.TOPOLOGY_ACKER_EXECUTORS How many executors to spawn for ackers.
static String	Config.TOPOLOGY_BOLTS_SLIDING_INTERVAL_COUNT
static String	Config.TOPOLOGY_BOLTS_SLIDING_INTERVAL_DURATION_MS
static String	Config.TOPOLOGY_BOLTS_TUPLE_TIMESTAMP_MAX_LAG_MS Bolt-specific configuration for windowed bolts to specify the maximum time lag of the tuple timestamp in milliseconds.
static String	Config.TOPOLOGY_BOLTS_WATERMARK_EVENT_INTERVAL_MS
static String	Config.TOPOLOGY_BOLTS_WINDOW_LENGTH_COUNT
static String	Config.TOPOLOGY_BOLTS_WINDOW_LENGTH_DURATION_MS
static String	Config.TOPOLOGY_COMPONENT_CPU_PCORE_PERCENT The config indicates the percentage of cpu for a core an instance(executor) of a component will use.
static String	Config.TOPOLOGY_COMPONENT_RESOURCES_OFFHEAP_MEMORY_MB The maximum amount of memory an instance of a spout/bolt will take off heap.
static String	Config.TOPOLOGY_COMPONENT_RESOURCES_ONHEAP_MEMORY_MB The maximum amount of memory an instance of a spout/bolt will take on heap.
static String	Config.TOPOLOGY_DISRUPTOR_BATCH_SIZE The number of tuples to batch before sending to the next thread.
static String	Config.TOPOLOGY_DISRUPTOR_BATCH_TIMEOUT_MILLIS The maximum age in milliseconds a batch can be before being sent to the next thread.
static String	Config.TOPOLOGY_EVENTLOGGER_EXECUTORS How many executors to spawn for event logger.
static String	Config.TOPOLOGY_ISOLATED_MACHINES The number of machines that should be used by this topology to isolate it from all others.
static String	Config.TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL See doc for TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS
static String	Config.TOPOLOGY_MAX_SPOUT_PENDING The maximum number of tuples that can be pending on a spout task at any given time.
static String	Config.TOPOLOGY_MAX_TASK_PARALLELISM The maximum parallelism allowed for a component in this topology.
static String	Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS The maximum amount of time given to the topology to fully process a message emitted by a spout.
static String	Config.TOPOLOGY_PRIORITY Sets the priority for a topology
static String	Config.TOPOLOGY_SHELLBOLT_MAX_PENDING Max pending tuples in one ShellBolt
static String	Config.TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS The amount of milliseconds the SleepEmptyEmitStrategy should sleep for.
static String	Config.TOPOLOGY_STATE_CHECKPOINT_INTERVAL Topology configuration to specify the checkpoint interval (in millis) at which the topology state is saved when IStatefulBolt bolts are involved.
static String	Config.TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS The maximum amount of time a component gives a source of state to synchronize before it requests synchronization again.
static String	Config.TOPOLOGY_STATS_SAMPLE_RATE The percentage of tuples to sample to produce stats for a task.
static String	Config.TOPOLOGY_SUBPROCESS_TIMEOUT_SECS How long a subprocess can go without heartbeating before the ShellSpout/ShellBolt tries to suicide itself.
static String	Config.TOPOLOGY_TASKS How many instances to create for a spout/bolt.
static String	Config.TOPOLOGY_TRIDENT_BATCH_EMIT_INTERVAL_MILLIS How often a batch can be emitted in a Trident topology.
static String	Config.TOPOLOGY_TRIDENT_WINDOWING_INMEMORY_CACHE_LIMIT Maximum number of tuples that can be stored inmemory cache in windowing operators for fast access without fetching them from store.
static String	Config.TOPOLOGY_WORKER_MAX_HEAP_SIZE_MB A per topology config that specifies the maximum amount of memory a worker can use for that specific topology
static String	Config.TOPOLOGY_WORKERS How many processes should be spawned around the cluster to execute this topology.
static String	Config.TRANSACTIONAL_ZOOKEEPER_PORT The port to use to connect to the transactional zookeeper servers.
static String	Config.UI_HEADER_BUFFER_BYTES The size of the header buffer for the UI in bytes
static String	Config.UI_HTTPS_PORT This port is used by Storm DRPC for receiving HTTPS (SSL) DPRC requests from clients.
static String	Config.UI_PORT Storm UI binds to this port.
static String	Config.WORKER_HEAP_MEMORY_MB The default heap memory size in MB per worker, used in the jvm -Xmx opts for launching the worker
static String	Config.WORKER_HEARTBEAT_FREQUENCY_SECS How often this worker should heartbeat to the supervisor.
static String	Config.WORKER_LOG_LEVEL_RESET_POLL_SECS How often a worker should check dynamic log level timeouts for expiration.