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

java.lang.Object
  extended by storm.trident.operation.BaseOperation
      extended by storm.trident.state.BaseQueryFunction<HBaseState,List<Values>>
          extended by org.apache.storm.hbase.trident.state.HBaseQuery
All Implemented Interfaces:
Serializable, EachOperation, Operation, QueryFunction<HBaseState,List<Values>>

public class HBaseQuery
extends BaseQueryFunction<HBaseState,List<Values>>

See Also:
Serialized Form

Constructor Summary
HBaseQuery()
           
 
Method Summary
 List<List<Values>> batchRetrieve(HBaseState hBaseState, List<TridentTuple> tridentTuples)
           
 void execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector)
           
 
Methods inherited from class storm.trident.operation.BaseOperation
cleanup, prepare
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface storm.trident.operation.Operation
cleanup, prepare
 

Constructor Detail

HBaseQuery

public HBaseQuery()
Method Detail

batchRetrieve

public List<List<Values>> batchRetrieve(HBaseState hBaseState,
                                        List<TridentTuple> tridentTuples)

execute

public void execute(TridentTuple tuples,
                    List<Values> values,
                    TridentCollector tridentCollector)


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