Uses of Annotation Type
org.apache.storm.validation.ConfigValidationAnnotations.IsPositiveNumber
Packages that use ConfigValidationAnnotations.IsPositiveNumber
-
Uses of ConfigValidationAnnotations.IsPositiveNumber in org.apache.storm
Fields in org.apache.storm with annotations of type ConfigValidationAnnotations.IsPositiveNumberModifier and TypeFieldDescriptionstatic final StringDaemonConfig.BLACKLIST_SCHEDULER_RESUME_TIMEThe number of seconds that the blacklisted slots or supervisor will be resumed.static final StringDaemonConfig.BLACKLIST_SCHEDULER_TOLERANCE_COUNTThe number of hit count that will trigger blacklist in tolerance time.static final StringDaemonConfig.BLACKLIST_SCHEDULER_TOLERANCE_TIMEThe number of seconds that the blacklist scheduler will concern of bad slots or supervisors.static final StringConfig.DRPC_INVOCATIONS_PORTThis port on Storm DRPC is used by DRPC topologies to receive function invocations and send results back.static final StringConfig.DRPC_INVOCATIONS_THREADSDRPC invocations thrift server worker threads.static final StringConfig.DRPC_MAX_BUFFER_SIZEThe maximum buffer size thrift should use when reading messages for DRPC.static final StringConfig.DRPC_PORTThis port is used by Storm DRPC for receiving DPRC requests from clients.static final StringConfig.DRPC_QUEUE_SIZEDRPC thrift server queue size.static final StringDaemonConfig.DRPC_REQUEST_TIMEOUT_SECSThe timeout on DRPC requests within the DRPC server.static final StringConfig.DRPC_WORKER_THREADSDRPC thrift server worker threads.static final StringHow often executor metrics should report to master, used for RPC heartbeat mode.static final StringDaemonConfig.LOGVIEWER_CLEANUP_AGE_MINSHow many minutes since a log was last modified for the log to be considered for clean-up.static final StringDaemonConfig.LOGVIEWER_CLEANUP_INTERVAL_SECSHow often to clean up old log files.static final StringDaemonConfig.LOGVIEWER_HTTPS_PORTStorm Logviewer HTTPS port.static final StringDaemonConfig.LOGVIEWER_MAX_PER_WORKER_LOGS_SIZE_MBThe maximum number of bytes per worker's files can take up in MB.static final StringDaemonConfig.LOGVIEWER_MAX_SUM_WORKER_LOGS_SIZE_MBThe maximum number of bytes all worker log files can take up in MB.static final StringDaemonConfig.LOGVIEWER_PORTHTTP UI port for log viewer.static final StringDaemonConfig.NIMBUS_BLOBSTORE_EXPIRATION_SECSDuring 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 final StringDaemonConfig.NIMBUS_CLEANUP_INBOX_FREQ_SECSHow often nimbus should wake the cleanup thread to clean the inbox.static final StringDaemonConfig.NIMBUS_CREDENTIAL_RENEW_FREQ_SECSHow often nimbus should wake up to renew credentials if needed.static final StringDaemonConfig.NIMBUS_EXECUTORS_PER_TOPOLOGYA number representing the maximum number of executors any single topology can acquire.static final StringDaemonConfig.NIMBUS_MONITOR_FREQ_SECSHow often nimbus should wake up to check heartbeats and do reassignments.static final StringConfig.NIMBUS_QUEUE_SIZENimbus thrift server queue size, default is 100000.static final StringDaemonConfig.NIMBUS_SLOTS_PER_TOPOLOGYA number representing the maximum number of workers any single topology can acquire.static final StringDaemonConfig.NIMBUS_SUPERVISOR_TIMEOUT_SECSHow long before a supervisor can go without heartbeating before nimbus considers it dead and stops assigning new work to it.static final StringDaemonConfig.NIMBUS_TASK_LAUNCH_SECSA special timeout used when a task is initially launched.static final StringDaemonConfig.NIMBUS_TASK_TIMEOUT_SECSHow long without heartbeating a task can go before nimbus will consider the task dead and reassign it to another location.static final StringThe maximum buffer size thrift should use when reading messages.static final StringConfig.NIMBUS_THRIFT_PORTWhich port the Thrift interface of Nimbus should run on.static final StringConfig.NIMBUS_THRIFT_THREADSThe number of threads that should be used by the nimbus thrift server.static final StringConfig.NUM_STAT_BUCKETSThe number of Buckets.static final StringConfig.PACEMAKER_CLIENT_MAX_THREADSThe maximum number of threads that should be used by the Pacemaker client.static final StringDaemonConfig.PACEMAKER_MAX_THREADSThe maximum number of threads that should be used by the Pacemaker.static final StringConfig.PACEMAKER_PORTThe port Pacemaker should run on.static final StringPacemaker Thrift Max Message Size (bytes).static final StringDaemonConfig.RESOURCE_AWARE_SCHEDULER_MAX_STATE_SEARCHstatic final StringThe maximum number of times that the RAS will attempt to schedule a topology.static final StringDaemonConfig.SCHEDULER_CONFIG_CACHE_EXPIRATION_SECSHow long before a scheduler considers its config cache expired.static final StringDaemonConfig.SCHEDULER_CONFIG_LOADER_POLLTIME_SECSIt is the frequency at which the plugin will call out to artifactory instead of returning the most recently cached result.static final StringDaemonConfig.SCHEDULER_CONFIG_LOADER_TIMEOUT_SECSIt is the amount of time an http connection to the artifactory server will wait before timing out.static final StringDaemonConfig.SCHEDULING_TIMEOUT_SECONDS_PER_TOPOLOGYMax time to attempt to schedule one topology.static final StringWhat chunk size to use for storm client to upload dependency jars.static final StringWhat buffer size to use for the blobstore uploads.static final StringSet replication factor for a blob in HDFS Blobstore Implementation.static StringDaemonConfig.STORM_CGROUP_MEMORY_LIMIT_TOLERANCE_MARGIN_MBPlease use STORM_SUPERVISOR_MEMORY_LIMIT_TOLERANCE_MARGIN_MB instead.static final StringDaemonConfig.STORM_CLUSTER_METRICS_CONSUMER_PUBLISH_INTERVAL_SECSHow often cluster metrics data is published to metrics consumer.static final StringNetty based messaging: The netty write buffer high watermark in bytes.static final StringNetty based messaging: The netty write buffer low watermark in bytes.static final StringNetty based messaging: The buffer size for send/recv buffer.static final StringNetty based messaging: The max # of milliseconds that a peer will wait.static final StringNetty based messaging: The min # of milliseconds that a peer will wait.static final StringNetty based messaging: The # of worker threads for the server.static final StringNetty based messaging: Sets the backlog value to specify when the channel binds to a local address.static StringDaemonConfig.STORM_SUPERVISOR_HARD_LIMIT_MEMORY_OVERAGE_MBIf the memory usage of a worker goes over its limit by this value is it shot immediately.static StringDaemonConfig.STORM_SUPERVISOR_HARD_MEMORY_LIMIT_MULTIPLIERA multiplier for the memory limit of a worker that will have the supervisor shoot it immediately. 1.0 means shoot the worker as soon as it goes over. 2.0 means shoot the worker if its usage is double what was requested.static StringDaemonConfig.STORM_SUPERVISOR_LOW_MEMORY_THRESHOLD_MBIf the amount of memory that is free in the system (either on the box or in the supervisor's cgroup) is below this number (in MB) consider the system to be in low memory mode and start shooting workers if they are over their limit.static StringDaemonConfig.STORM_SUPERVISOR_MEDIUM_MEMORY_GRACE_PERIOD_MSThe number of milliseconds that a worker is allowed to be over their limit when there is a medium amount of memory free in the system.static StringDaemonConfig.STORM_SUPERVISOR_MEDIUM_MEMORY_THRESHOLD_MBIf the amount of memory that is free in the system (either on the box or in the supervisor's cgroup) is below this number (in MB) consider the system to be a little low on memory and start shooting workers if they are over their limit for a given grace period STORM_SUPERVISOR_MEDIUM_MEMORY_GRACE_PERIOD_MS.static StringDaemonConfig.STORM_SUPERVISOR_MEMORY_LIMIT_TOLERANCE_MARGIN_MBMemory given to each worker for free (because java and storm have some overhead).static StringDaemonConfig.STORM_WORKER_CGROUP_CPU_LIMITthe manually set cpu share for each CGroup on supervisor node.static StringDaemonConfig.STORM_WORKER_CGROUP_MEMORY_MB_LIMITthe manually set memory limit (in MB) for each CGroup on supervisor node.static StringDaemonConfig.STORM_WORKER_MIN_CPU_PCORE_PERCENTThe config indicates the minimum percentage of cpu for a core that a worker will use.static StringDaemonConfig.STORM_WORKER_TOKEN_LIFE_TIME_HOURSThe number of hours a worker token is valid for.static final StringConfig.STORM_ZOOKEEPER_PORTThe port Storm will use to connect to each of the ZooKeeper servers.static final StringDaemonConfig.SUPERVISOR_BLOBSTORE_DOWNLOAD_MAX_RETRIESMaximum number of retries a supervisor is allowed to make for downloading a blob.static final StringDaemonConfig.SUPERVISOR_BLOBSTORE_DOWNLOAD_THREAD_COUNTWhat blobstore download parallelism the supervisor should use.static final StringConfig.SUPERVISOR_CPU_CAPACITYThe total amount of CPU resources a supervisor is allowed to give to its workers.static final StringDaemonConfig.SUPERVISOR_LOCALIZER_CACHE_CLEANUP_INTERVAL_MSThe distributed cache cleanup interval.static final StringDaemonConfig.SUPERVISOR_LOCALIZER_CACHE_TARGET_SIZE_MBThe distributed cache target size in MB.static final StringDaemonConfig.SUPERVISOR_LOCALIZER_UPDATE_BLOB_INTERVAL_SECSThe distributed cache interval for checking for blobs to update.static final StringThe total amount of memory (in MiB) a supervisor is allowed to give to its workers.static final StringDaemonConfig.SUPERVISOR_MONITOR_FREQUENCY_SECSHow often the supervisor checks the worker heartbeats to see if any of them need to be restarted.static final StringConfig.SUPERVISOR_QUEUE_SIZEstatic final Stringstatic final StringConfig.SUPERVISOR_THRIFT_PORTstatic final StringConfig.SUPERVISOR_THRIFT_THREADSstatic final StringHow many seconds to allow for graceful worker shutdown when killing workers before resorting to force kill.static final StringDaemonConfig.SUPERVISOR_WORKER_START_TIMEOUT_SECSHow long a worker can go without heartbeating during the initial launch before the supervisor tries to restart the worker process.static final StringHow long a worker can go without heartbeating before the supervisor tries to restart the worker process.static final StringConfig.TASK_CREDENTIALS_POLL_SECSHow often a task should sync credentials, worst case.static final StringHow often a task should heartbeat its status to the Pacamker.static final StringConfig.TASK_REFRESH_POLL_SECSHow 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 final StringThe config indicates the percentage of cpu for a core an instance(executor) of an acker will use.static final StringConfig.TOPOLOGY_ACKER_EXECUTORSHow many executors to spawn for ackers.static final StringThe maximum amount of memory an instance of an acker will take off heap.static final StringThe maximum amount of memory an instance of an acker will take on heap.static final StringHow often a worker should check and notify upstream workers about its tasks that are no longer experiencing BP and able to receive new messages.static final StringConfigures park time if using WaitStrategyPark for BackPressure.static final StringConfigures steps used to determine progression to the next level of wait .. if using WaitStrategyProgressive for BackPressure.static final StringConfigures steps used to determine progression to the next level of wait .. if using WaitStrategyProgressive for BackPressure.static final StringConfigures sleep time if using WaitStrategyProgressive for BackPressure.static final StringHow often to send flush tuple to the executors for flushing out batched events.static final StringConfigures park time for WaitStrategyPark.static final StringConfigures number of iterations to spend in level 1 of WaitStrategyProgressive, before progressing to level 2.static final StringConfigures number of iterations to spend in level 2 of WaitStrategyProgressive, before progressing to level 3.static final StringConfigures sleep time for WaitStrategyProgressive.static final Stringstatic final Stringstatic final StringBolt-specific configuration for windowed bolts to specify the maximum time lag of the tuple timestamp in milliseconds.static final Stringstatic final Stringstatic final Stringstatic final StringThe config indicates the percentage of cpu for a core an instance(executor) of a component will use.static final StringThe maximum amount of memory an instance of a spout/bolt will take off heap.static final StringThe maximum amount of memory an instance of a spout/bolt will take on heap.static final StringHow many executors to spawn for event logger.static final StringIf number of items in task's overflowQ exceeds this, new messages coming from other workers to this task will be dropped This prevents OutOfMemoryException that can occur in rare scenarios in the presence of BackPressure.static final StringThe size of the receive queue for each executor.static final StringConfig.TOPOLOGY_ISOLATED_MACHINESThe maximum number of machines that should be used by this topology.static final StringThis signifies the load congestion among target tasks in scope.static final StringThis signifies the load congestion among target tasks in scope.static final StringSee doc forConfig.TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS.static final StringConfig.TOPOLOGY_MAX_SPOUT_PENDINGThe maximum number of tuples that can be pending on a spout task at any given time.static final StringThe maximum parallelism allowed for a component in this topology.static final StringThe maximum amount of time given to the topology to fully process a message emitted by a spout.static final StringThe config indicates the percentage of cpu for a core an instance(executor) of a metrics consumer will use.static final StringThe maximum amount of memory an instance of a metrics consumer will take off heap.static final StringThe maximum amount of memory an instance of a metrics consumer will take on heap.static final StringConfig.TOPOLOGY_PRIORITYSets the priority for a topology.static final StringConfig.TOPOLOGY_PRODUCER_BATCH_SIZEThe number of tuples to batch before sending to the destination executor.static final StringHow many ackers to put in when launching a new worker until we run out of ackers.static final StringThe maximum number of states that will be searched looking for a solution in resource aware strategies, e.g.static final StringThe maximum number of seconds to spend scheduling a topology using resource aware strategies, e.g.static final StringMax pending tuples in one ShellBolt.static final StringThe amount of milliseconds the SleepEmptyEmitStrategy should sleep for.static final StringConfig.TOPOLOGY_SPOUT_RECVQ_SKIPSCheck recvQ after every N invocations of Spout's nextTuple() [when ACKing is disabled].static final StringConfigures park time for WaitStrategyPark for spout.static final StringConfigures number of iterations to spend in level 1 of WaitStrategyProgressive, before progressing to level 2.static final StringConfigures number of iterations to spend in level 2 of WaitStrategyProgressive, before progressing to level 3.static final StringConfigures sleep time for WaitStrategyProgressive.static final StringTopology configuration to specify the checkpoint interval (in millis) at which the topology state is saved whenIStatefulBoltbolts are involved.static final StringThe maximum amount of time a component gives a source of state to synchronize before it requests synchronization again.static final StringConfig.TOPOLOGY_STATS_SAMPLE_RATEThe percentage of tuples to sample to produce stats for a task.static final StringHow long a subprocess can go without heartbeating before the ShellSpout/ShellBolt tries to suicide itself.static final StringConfig.TOPOLOGY_TASKSHow many instances to create for a spout/bolt.static final StringConfig.TOPOLOGY_TRANSFER_BATCH_SIZEThe size of the transfer queue for each worker.static final StringThe size of the transfer queue for each worker.static final StringHow often a batch can be emitted in a Trident topology.static final StringMaximum number of tuples that can be stored inmemory cache in windowing operators for fast access without fetching them from store.static final StringTopology configuration to specify the V2 metrics tick interval in seconds.static final StringA per topology config that specifies the maximum amount of memory a worker can use for that specific topology.static final StringConfig.TOPOLOGY_WORKER_TIMEOUT_SECSTopology configurable worker heartbeat timeout before the supervisor tries to restart the worker process.static final StringConfig.TOPOLOGY_WORKERSHow many processes should be spawned around the cluster to execute this topology.static final StringConfig.TRANSACTIONAL_ZOOKEEPER_PORTThe port to use to connect to the transactional zookeeper servers.static final StringDaemonConfig.UI_HEADER_BUFFER_BYTESThe size of the header buffer for the UI in bytes.static final StringDaemonConfig.UI_HTTPS_PORTThis port is used by Storm UI for receiving HTTPS (SSL) requests from clients.static final StringDaemonConfig.UI_PORTStorm UI binds to this port.static final StringInterval to check for the worker to check for updated blobs and refresh worker state accordingly.static final StringConfig.WORKER_HEAP_MEMORY_MBThe default heap memory size in MB per worker, used in the jvm -Xmx opts for launching the worker.static final StringHow often this worker should heartbeat to the supervisor.static final StringHow often a worker should check dynamic log level timeouts for expiration.static final StringConfig.WORKER_MAX_TIMEOUT_SECSEnforce maximum onConfig.TOPOLOGY_WORKER_TIMEOUT_SECS. -
Uses of ConfigValidationAnnotations.IsPositiveNumber in org.apache.storm.hdfs.spout
Fields in org.apache.storm.hdfs.spout with annotations of type ConfigValidationAnnotations.IsPositiveNumberModifier and TypeFieldDescriptionstatic final StringConfigs.COMMIT_FREQ_COUNTDeprecated.static final StringConfigs.COMMIT_FREQ_SECDeprecated.please useHdfsSpout.setCommitFrequencySec(int)static final StringConfigs.LOCK_TIMEOUTDeprecated.please useHdfsSpout.setLockTimeoutSec(int)static final StringConfigs.MAX_OUTSTANDINGDeprecated.please useHdfsSpout.setMaxOutstanding(int)
HdfsSpout.setCommitFrequencyCount(int)