Package org.apache.storm.redis.state
Class RedisKeyValueStateProvider
- java.lang.Object
-
- org.apache.storm.redis.state.RedisKeyValueStateProvider
-
- All Implemented Interfaces:
StateProvider
public class RedisKeyValueStateProvider extends Object implements StateProvider
ProvidesRedisKeyValueState
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
RedisKeyValueStateProvider.StateConfig
-
Constructor Summary
Constructors Constructor Description RedisKeyValueStateProvider()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description State
newState(String namespace, Map<String,Object> topoConf, TopologyContext context)
Returns a new state instance.
-
-
-
Method Detail
-
newState
public State newState(String namespace, Map<String,Object> topoConf, TopologyContext context)
Description copied from interface:StateProvider
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.- Specified by:
newState
in interfaceStateProvider
- 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.
-
-