org.apache.storm.hbase.trident.state
Class HBaseQuery
java.lang.Object
storm.trident.operation.BaseOperation
storm.trident.state.BaseQueryFunction<HBaseState,List<Values>>
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HBaseQuery
public HBaseQuery()
batchRetrieve
public List<List<Values>> batchRetrieve(HBaseState hBaseState,
List<TridentTuple> tridentTuples)
execute
public void execute(TridentTuple tuples,
List<Values> values,
TridentCollector tridentCollector)
Copyright © 2015 The Apache Software Foundation. All Rights Reserved.