Uses of Interface
org.apache.storm.state.State
-
Packages that use State Package Description org.apache.storm.redis.state org.apache.storm.state org.apache.storm.topology org.apache.storm.topology.base -
-
Uses of State in org.apache.storm.redis.state
Classes in org.apache.storm.redis.state that implement State Modifier and Type Class Description classRedisKeyValueState<K,V>A redis based implementation that persists the state in Redis.Methods in org.apache.storm.redis.state that return State Modifier and Type Method Description StateRedisKeyValueStateProvider. newState(String namespace, Map<String,Object> topoConf, TopologyContext context) -
Uses of State in org.apache.storm.state
Subinterfaces of State in org.apache.storm.state Modifier and Type Interface Description interfaceKeyValueState<K,V>A state that supports key-value mappings.Classes in org.apache.storm.state that implement State Modifier and Type Class Description classInMemoryKeyValueState<K,V>An in-memory implementation of theState.Methods in org.apache.storm.state that return State Modifier and Type Method Description static StateStateFactory. getState(String namespace, Map<String,Object> topoConf, TopologyContext context)Returns a new state instance using theConfig.TOPOLOGY_STATE_PROVIDERor aInMemoryKeyValueStateif no provider is configured.StateInMemoryKeyValueStateProvider. newState(String namespace, Map<String,Object> topoConf, TopologyContext context)StateStateProvider. 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 State Modifier and Type Interface Description interfaceIStatefulBolt<T extends State>A bolt abstraction for supporting stateful computation.interfaceIStatefulComponent<T extends State>Common methods for stateful components in the topology.interfaceIStatefulWindowedBolt<T extends State>A windowed bolt abstraction for supporting windowing operation with state.classPersistentWindowedBoltExecutor<T extends State>Wraps aIStatefulWindowedBoltand handles the execution.classStatefulBoltExecutor<T extends State>Wraps aIStatefulBoltand manages the state of the bolt.classStatefulWindowedBoltExecutor<T extends State>Wraps aIStatefulWindowedBoltand handles the execution.Methods in org.apache.storm.topology with type parameters of type State Modifier and Type Method Description <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 State Modifier and Type Class Description classBaseStatefulBolt<T extends State>classBaseStatefulWindowedBolt<T extends State>
-