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 TypeClassDescriptionclassRedisKeyValueState<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 TypeInterfaceDescriptioninterfaceKeyValueState<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 StateReturns a new state instance using theConfig.TOPOLOGY_STATE_PROVIDERor aInMemoryKeyValueStateif 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 TypeInterfaceDescriptioninterfaceIStatefulBolt<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 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 TypeClassDescriptionclassBaseStatefulBolt<T extends State>classBaseStatefulWindowedBolt<T extends State>