org.apache.storm.state

Interface StateProvider

All Known Implementing Classes:

InMemoryKeyValueStateProvider

public interface StateProvider

Used by the StateFactory to create a new state instances.

Method Summary

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

Method Detail

newState

State newState(java.lang.String namespace,
               java.util.Map<java.lang.String,java.lang.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 state

topoConf - the storm topology configuration

context - the TopologyContext

Returns:

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