Uses of Annotation Type
org.apache.storm.validation.ConfigValidationAnnotations.NotNull

Packages that use ConfigValidationAnnotations.NotNull

Package	Description
org.apache.storm

Uses of ConfigValidationAnnotations.NotNull in org.apache.storm

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

Modifier and Type	Field	Description
static final String	DaemonConfig.BLACKLIST_SCHEDULER_REPORTER	The class that the blacklist scheduler will report the blacklist.
static final String	DaemonConfig.BLACKLIST_SCHEDULER_STRATEGY	The class that specifies the eviction strategy to use in blacklist scheduler.
static final String	DaemonConfig.DRPC_REQUEST_TIMEOUT_SECS	The timeout on DRPC requests within the DRPC server.
static final String	DaemonConfig.RESOURCE_AWARE_SCHEDULER_PRIORITY_STRATEGY	the class that specifies the scheduling priority strategy to use in ResourceAwareScheduler.
static final String	DaemonConfig.STORM_CLUSTER_METRICS_CONSUMER_PUBLISH_INTERVAL_SECS	How often cluster metrics data is published to metrics consumer.
static final String	DaemonConfig.STORM_METRIC_PROCESSOR_CLASS	Class implementing WorkerMetricsProcessor.
static final String	DaemonConfig.STORM_METRIC_STORE_CLASS	Class implementing MetricStore.
static final String	Config.STORM_NETWORK_TOPOGRAPHY_PLUGIN	What Network Topography detection classes should we use.
static String	DaemonConfig.STORM_OCI_CGROUP_PARENT	The cgroup root for oci container.
static String	Config.STORM_OCI_CGROUP_ROOT	The root of cgroup for oci to use.
static String	DaemonConfig.STORM_OCI_NSCD_DIR	The directory of nscd - name service cache daemon, e.g.
static final String	DaemonConfig.SUPERVISOR_SLOTS_PORTS	A list of ports that can run workers on this supervisor.
static final String	DaemonConfig.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 final String	Config.SUPERVISOR_WORKER_TIMEOUT_SECS	How long a worker can go without heartbeating before the supervisor tries to restart the worker process.
static final String	Config.TOPOLOGY_BACKPRESSURE_CHECK_MILLIS	How 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 String	Config.TOPOLOGY_BACKPRESSURE_WAIT_PARK_MICROSEC	Configures park time if using WaitStrategyPark for BackPressure.
static final String	Config.TOPOLOGY_BACKPRESSURE_WAIT_PROGRESSIVE_LEVEL1_COUNT	Configures steps used to determine progression to the next level of wait .. if using WaitStrategyProgressive for BackPressure.
static final String	Config.TOPOLOGY_BACKPRESSURE_WAIT_PROGRESSIVE_LEVEL2_COUNT	Configures steps used to determine progression to the next level of wait .. if using WaitStrategyProgressive for BackPressure.
static final String	Config.TOPOLOGY_BACKPRESSURE_WAIT_PROGRESSIVE_LEVEL3_SLEEP_MILLIS	Configures sleep time if using WaitStrategyProgressive for BackPressure.
static final String	Config.TOPOLOGY_BATCH_FLUSH_INTERVAL_MILLIS	How often to send flush tuple to the executors for flushing out batched events.
static final String	Config.TOPOLOGY_BOLT_WAIT_PARK_MICROSEC	Configures park time for WaitStrategyPark.
static final String	Config.TOPOLOGY_BOLT_WAIT_PROGRESSIVE_LEVEL1_COUNT	Configures number of iterations to spend in level 1 of WaitStrategyProgressive, before progressing to level 2.
static final String	Config.TOPOLOGY_BOLT_WAIT_PROGRESSIVE_LEVEL2_COUNT	Configures number of iterations to spend in level 2 of WaitStrategyProgressive, before progressing to level 3.
static final String	Config.TOPOLOGY_BOLT_WAIT_PROGRESSIVE_LEVEL3_SLEEP_MILLIS	Configures sleep time for WaitStrategyProgressive.
static final String	Config.TOPOLOGY_DISABLE_LOADAWARE_MESSAGING	Disable load aware grouping support.
static final String	Config.TOPOLOGY_EXECUTOR_OVERFLOW_LIMIT	If 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 String	Config.TOPOLOGY_LOCALITYAWARE_HIGHER_BOUND	This signifies the load congestion among target tasks in scope.
static final String	Config.TOPOLOGY_LOCALITYAWARE_LOWER_BOUND	This signifies the load congestion among target tasks in scope.
static final 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 final String	Config.TOPOLOGY_PRODUCER_BATCH_SIZE	The number of tuples to batch before sending to the destination executor.
static final String	Config.TOPOLOGY_SCHEDULER_STRATEGY	The strategy to use when scheduling a topology with Resource Aware Scheduler.
static final String	Config.TOPOLOGY_SHELLBOLT_MAX_PENDING	Max pending tuples in one ShellBolt.
static final String	Config.TOPOLOGY_SPOUT_RECVQ_SKIPS	Check recvQ after every N invocations of Spout's nextTuple() [when ACKing is disabled].
static final String	Config.TOPOLOGY_SPOUT_WAIT_PARK_MICROSEC	Configures park time for WaitStrategyPark for spout.
static final String	Config.TOPOLOGY_SPOUT_WAIT_PROGRESSIVE_LEVEL1_COUNT	Configures number of iterations to spend in level 1 of WaitStrategyProgressive, before progressing to level 2.
static final String	Config.TOPOLOGY_SPOUT_WAIT_PROGRESSIVE_LEVEL2_COUNT	Configures number of iterations to spend in level 2 of WaitStrategyProgressive, before progressing to level 3.
static final String	Config.TOPOLOGY_SPOUT_WAIT_PROGRESSIVE_LEVEL3_SLEEP_MILLIS	Configures sleep time for WaitStrategyProgressive.
static final 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 final String	Config.TOPOLOGY_WORKER_TIMEOUT_SECS	Topology configurable worker heartbeat timeout before the supervisor tries to restart the worker process.
static final String	Config.WORKER_MAX_TIMEOUT_SECS	Enforce maximum on Config.TOPOLOGY_WORKER_TIMEOUT_SECS.