Package org.apache.storm.state
Interface StateProvider
-
- All Known Implementing Classes:
InMemoryKeyValueStateProvider
,RedisKeyValueStateProvider
public interface StateProvider
Used by theStateFactory
to create a new state instances.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description State
newState(String namespace, Map<String,Object> topoConf, TopologyContext context)
Returns a new state instance.
-
-
-
Method Detail
-
newState
State newState(String namespace, Map<String,Object> topoConf, TopologyContext context)
Returns a new state instance. Each state belongs unique namespace which is typically the componentid-task of the task, so that each task can have its own unique state.- Parameters:
namespace
- a namespace of the statetopoConf
- the storm topology configurationcontext
- theTopologyContext
- Returns:
- a previously saved state if one exists otherwise a newly initialized state.
-
-