Uses of Interface
org.apache.storm.state.State
Package
Description
-
Uses of State in org.apache.storm.redis.state
Modifier and TypeClassDescriptionclass
RedisKeyValueState<K,
V> A redis based implementation that persists the state in Redis. -
Uses of State in org.apache.storm.state
Modifier and TypeInterfaceDescriptioninterface
KeyValueState<K,
V> A state that supports key-value mappings.Modifier 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
Modifier 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.Modifier 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
Modifier and TypeClassDescriptionclass
BaseStatefulBolt<T extends State>
class
BaseStatefulWindowedBolt<T extends State>