Package 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	Description
InMemoryKeyValueStateProvider()

Method Summary

Modifier and Type	Method	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 Details

InMemoryKeyValueStateProvider

public InMemoryKeyValueStateProvider()

Method Details

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.