org.apache.storm.state

Class InMemoryKeyValueStateProvider

java.lang.Object

org.apache.storm.state.InMemoryKeyValueStateProvider

All Implemented Interfaces:

StateProvider

public class InMemoryKeyValueStateProvider
extends Object
implements StateProvider

Provides InMemoryKeyValueState

Constructor Summary

Constructors

Constructor and Description
InMemoryKeyValueStateProvider()

Method Summary

Modifier and Type	Method and Description
State	newState(String namespace, Map stormConf, 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

InMemoryKeyValueStateProvider

public InMemoryKeyValueStateProvider()

Method Detail

newState

public State newState(String namespace,
                      Map stormConf,
                      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

stormConf - the storm topology configuration

context - the TopologyContext

Returns:

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