Uses of Interface
org.apache.storm.state.State
Packages that use State
Package
Description
-
Uses of State in org.apache.storm.redis.state
Classes in org.apache.storm.redis.state that implement StateModifier and TypeClassDescriptionclass
RedisKeyValueState<K,
V> A redis based implementation that persists the state in Redis.Methods in org.apache.storm.redis.state that return State -
Uses of State in org.apache.storm.state
Subinterfaces of State in org.apache.storm.stateModifier and TypeInterfaceDescriptioninterface
KeyValueState<K,
V> A state that supports key-value mappings.Classes in org.apache.storm.state that implement StateMethods in org.apache.storm.state that return StateModifier and TypeMethodDescriptionstatic State
Returns a new state instance using theConfig.TOPOLOGY_STATE_PROVIDER
or aInMemoryKeyValueState
if no provider is configured.InMemoryKeyValueStateProvider.newState
(String namespace, Map<String, Object> topoConf, TopologyContext context) Returns a new state instance. -
Uses of State in org.apache.storm.topology
Classes in org.apache.storm.topology with type parameters of type StateModifier and TypeInterfaceDescriptioninterface
IStatefulBolt<T extends State>
A bolt abstraction for supporting stateful computation.interface
IStatefulComponent<T extends State>
Common methods for stateful components in the topology.interface
IStatefulWindowedBolt<T extends State>
A windowed bolt abstraction for supporting windowing operation with state.class
PersistentWindowedBoltExecutor<T extends State>
Wraps aIStatefulWindowedBolt
and handles the execution.class
StatefulBoltExecutor<T extends State>
Wraps aIStatefulBolt
and manages the state of the bolt.class
StatefulWindowedBoltExecutor<T extends State>
Wraps aIStatefulWindowedBolt
and handles the execution.Methods in org.apache.storm.topology with type parameters of type StateModifier and TypeMethodDescription<T extends State>
BoltDeclarerTopologyBuilder.setBolt
(String id, IStatefulBolt<T> bolt) Define a new bolt in this topology.<T extends State>
BoltDeclarerTopologyBuilder.setBolt
(String id, IStatefulBolt<T> bolt, Number parallelismHint) Define a new bolt in this topology.<T extends State>
BoltDeclarerTopologyBuilder.setBolt
(String id, IStatefulWindowedBolt<T> bolt) Define a new bolt in this topology.<T extends State>
BoltDeclarerTopologyBuilder.setBolt
(String id, IStatefulWindowedBolt<T> bolt, Number parallelismHint) Define a new bolt in this topology. -
Uses of State in org.apache.storm.topology.base
Classes in org.apache.storm.topology.base with type parameters of type StateModifier and TypeClassDescriptionclass
BaseStatefulBolt<T extends State>
class
BaseStatefulWindowedBolt<T extends State>