org.apache.storm.hbase.trident.state
Class HBaseState

java.lang.Object
  extended by org.apache.storm.hbase.trident.state.HBaseState
All Implemented Interfaces:
State

public class HBaseState
extends Object
implements State


Nested Class Summary
static class HBaseState.Options
           
 
Constructor Summary
protected HBaseState(Map map, int partitionIndex, int numPartitions, HBaseState.Options options)
           
 
Method Summary
 List<List<Values>> batchRetrieve(List<TridentTuple> tridentTuples)
           
 void beginCommit(Long aLong)
           
 void commit(Long aLong)
           
protected  void prepare()
           
 void updateState(List<TridentTuple> tuples, TridentCollector collector)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

HBaseState

protected HBaseState(Map map,
                     int partitionIndex,
                     int numPartitions,
                     HBaseState.Options options)
Method Detail

prepare

protected void prepare()

beginCommit

public void beginCommit(Long aLong)
Specified by:
beginCommit in interface State

commit

public void commit(Long aLong)
Specified by:
commit in interface State

updateState

public void updateState(List<TridentTuple> tuples,
                        TridentCollector collector)

batchRetrieve

public List<List<Values>> batchRetrieve(List<TridentTuple> tridentTuples)


Copyright © 2016 The Apache Software Foundation. All Rights Reserved.