org.apache.storm.hbase.state

Class HBaseKeyValueStateProvider

java.lang.Object

org.apache.storm.hbase.state.HBaseKeyValueStateProvider

All Implemented Interfaces:

StateProvider

public class HBaseKeyValueStateProvider
extends Object
implements StateProvider

Provides HBaseKeyValueState.

Constructor Summary

Constructors

Constructor and Description
HBaseKeyValueStateProvider()

Method Summary

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

HBaseKeyValueStateProvider

public HBaseKeyValueStateProvider()

Method Detail

newState

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