Uses of Annotation Type
org.apache.storm.validation.ConfigValidationAnnotations.IsInteger
Packages that use ConfigValidationAnnotations.IsInteger
-
Uses of ConfigValidationAnnotations.IsInteger in org.apache.storm
Fields in org.apache.storm with annotations of type ConfigValidationAnnotations.IsIntegerModifier and TypeFieldDescriptionstatic final StringDaemonConfig.DRPC_HTTP_PORTThis port is used by Storm DRPC for receiving HTTP DPRC requests from clients.static final StringDaemonConfig.DRPC_HTTPS_PORTThis port is used by Storm DRPC for receiving HTTPS (SSL) DPRC requests from clients.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_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_PORTHTTP UI port for log viewer.static final StringDaemonConfig.NIMBUS_ASSIGNMENTS_SERVICE_THREAD_QUEUE_SIZEThis controls the number of working thread queue size of assignment service.static final StringDaemonConfig.NIMBUS_ASSIGNMENTS_SERVICE_THREADSThis controls the number of working threads for distributing master assignments to supervisors.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_CODE_SYNC_FREQ_SECSHow often nimbus's background thread to sync code for missing topologies should run.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_FILE_COPY_EXPIRATION_SECSDuring upload/download with the master, how long an upload or download connection is idle before nimbus considers it dead and drops the connection.static final StringDaemonConfig.NIMBUS_INBOX_JAR_EXPIRATION_SECSThe length of time a jar file lives in the inbox before being deleted by the cleanup thread.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 StringDaemonConfig.NIMBUS_TOPOLOGY_BLOBSTORE_DELETION_DELAY_MSThis controls the number of milliseconds nimbus will wait before deleting a topology blobstore once detected it is able to delete.static final StringConfig.NUM_STAT_BUCKETSThe number of Buckets.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 final StringMax no.of seconds group mapping service will cache user groupsstatic 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 # of worker threads for the client.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 final StringDaemonConfig.STORM_NETTY_FLUSH_CHECK_INTERVAL_MSWe check with this interval that whether the Netty channel is writable and try to write pending messages.static final StringIf the Netty messaging layer is busy, the Netty client will try to batch message as more as possible up to the size of STORM_NETTY_MESSAGE_BATCH_SIZE bytes.static final StringDaemonConfig.STORM_OCI_LAYER_MOUNTS_TO_KEEPTarget count of OCI layer mounts that we should keep on disk at one time.static final StringDaemonConfig.STORM_ROCKSDB_METADATA_STRING_CACHE_CAPACITYRocksDB metadata cache capacity.static final StringDaemonConfig.STORM_ROCKSDB_METRIC_DELETION_PERIOD_HOURSRocksDB setting for period of metric deletion thread.static final StringDaemonConfig.STORM_ROCKSDB_METRIC_RETENTION_HOURSRocksDB setting for length of metric retention.static final StringHow long before a Thrift Client socket hangs before timeout and restart the socket.static final StringThe connection timeout for clients to ZooKeeper.static final StringConfig.STORM_ZOOKEEPER_PORTThe port Storm will use to connect to each of the ZooKeeper servers.static final StringThe interval between retries of a Zookeeper operation.static final StringThe ceiling of the interval between retries of a Zookeeper operation.static final StringConfig.STORM_ZOOKEEPER_RETRY_TIMESThe number of times to retry a Zookeeper operation.static final StringThe session timeout for clients to ZooKeeper.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 StringDaemonConfig.SUPERVISOR_HEARTBEAT_FREQUENCY_SECShow often the supervisor sends a heartbeat to the master.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 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 StringConfig.SUPERVISOR_THRIFT_PORTstatic final StringHow long before a supervisor Thrift Client socket hangs before timeout and restart the socket.static final StringConfig.SUPERVISOR_THRIFT_THREADSstatic final Stringmax timeout for supervisor reported heartbeats when master gains leadership.static 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 StringConfig.TOPOLOGY_ACKER_EXECUTORSHow many executors to spawn for ackers.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 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 StringHow often to send flush tuple to the executors for flushing out batched events.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 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 time period that builtin metrics data in bucketed into.static final StringThe interval in seconds to use for determining whether to throttle error reported to Zookeeper.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 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 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 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 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 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 StringHow often a tick tuple from the "__system" component and "__tick" stream should be sent to tasks.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 StringThe size of the shared thread pool for worker tasks to make use of.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_PAGINATIONStorm UI drop-down pagination value.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.IsInteger in org.apache.storm.hdfs.spout
Fields in org.apache.storm.hdfs.spout with annotations of type ConfigValidationAnnotations.IsIntegerModifier 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)