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

Provides RedisKeyValueState.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RedisKeyValueStateProvider.StateConfig

Constructor Summary

Constructors

Constructor and Description
RedisKeyValueStateProvider()

Method Summary

Modifier and Type	Method and Description
State	newState(String namespace, Map<String,Object> topoConf, TopologyContext context) Returns a new state instance.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RedisKeyValueStateProvider

public RedisKeyValueStateProvider()

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 interface StateProvider

Parameters:

namespace - a namespace of the state

topoConf - the storm topology configuration

context - the TopologyContext

Returns:

a previously saved state if one exists otherwise a newly initialized state.