Class TupleCollectionGet
java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.state.BaseQueryFunction<State,Iterator<List<Object>>>
org.apache.storm.trident.operation.builtin.TupleCollectionGet
- All Implemented Interfaces:
Serializable
,EachOperation
,Operation
,QueryFunction<State,
Iterator<List<Object>>>
- See Also:
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionbatchRetrieve
(State state, List<TridentTuple> args) void
execute
(TridentTuple tuple, Iterator<List<Object>> tuplesIterator, TridentCollector collector) Methods inherited from class org.apache.storm.trident.operation.BaseOperation
cleanup, prepare
-
Constructor Details
-
TupleCollectionGet
public TupleCollectionGet()
-
-
Method Details
-
batchRetrieve
-
execute
public void execute(TridentTuple tuple, Iterator<List<Object>> tuplesIterator, TridentCollector collector)
-