Class InMemoryKeyValueStateProvider

java.lang.Object
org.apache.storm.state.InMemoryKeyValueStateProvider
All Implemented Interfaces:
StateProvider

public class InMemoryKeyValueStateProvider extends Object implements StateProvider
  • 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.