Uses of Annotation Interface
org.apache.storm.validation.ConfigValidationAnnotations.NotNull
Packages that use ConfigValidationAnnotations.NotNull
-
Uses of ConfigValidationAnnotations.NotNull in org.apache.storm
Fields in org.apache.storm with annotations of type ConfigValidationAnnotations.NotNullModifier and TypeFieldDescriptionstatic final StringDaemonConfig.BLACKLIST_SCHEDULER_REPORTERThe class that the blacklist scheduler will report the blacklist.static final StringDaemonConfig.BLACKLIST_SCHEDULER_STRATEGYThe class that specifies the eviction strategy to use in blacklist scheduler.static final StringDaemonConfig.DRPC_REQUEST_TIMEOUT_SECSThe timeout on DRPC requests within the DRPC server.static final StringDaemonConfig.RESOURCE_AWARE_SCHEDULER_PRIORITY_STRATEGYthe class that specifies the scheduling priority strategy to use in ResourceAwareScheduler.static final StringDaemonConfig.STORM_CLUSTER_METRICS_CONSUMER_PUBLISH_INTERVAL_SECSHow often cluster metrics data is published to metrics consumer.static final StringDaemonConfig.STORM_METRIC_PROCESSOR_CLASSClass implementing WorkerMetricsProcessor.static final StringDaemonConfig.STORM_METRIC_STORE_CLASSClass implementing MetricStore.static final StringWhat Network Topography detection classes should we use.static StringDaemonConfig.STORM_OCI_CGROUP_PARENTThe cgroup root for oci container.static StringConfig.STORM_OCI_CGROUP_ROOTThe root of cgroup for oci to use.static StringDaemonConfig.STORM_OCI_NSCD_DIRThe directory of nscd - name service cache daemon, e.g.static final StringDaemonConfig.SUPERVISOR_SLOTS_PORTSA list of ports that can run workers on this supervisor.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 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 ..static final StringConfigures steps used to determine progression to the next level of wait ..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 StringDisable load aware grouping support.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 StringThis signifies the load congestion among target tasks in scope.static final StringThis signifies the load congestion among target tasks in scope.static final StringThe maximum amount of time given to the topology to fully process a message emitted by a spout.static final StringConfig.TOPOLOGY_PRODUCER_BATCH_SIZEThe number of tuples to batch before sending to the destination executor.static final StringConfig.TOPOLOGY_SCHEDULER_STRATEGYThe strategy to use when scheduling a topology with Resource Aware Scheduler.static final StringMax pending tuples in one ShellBolt.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 StringThe maximum amount of time a component gives a source of state to synchronize before it requests synchronization again.static final StringConfig.TOPOLOGY_WORKER_TIMEOUT_SECSTopology configurable worker heartbeat timeout before the supervisor tries to restart the worker process.static final StringConfig.WORKER_MAX_TIMEOUT_SECSEnforce maximum onConfig.TOPOLOGY_WORKER_TIMEOUT_SECS.