Package org.apache.storm.trident.planner
Interface TupleReceiver
- All Known Subinterfaces:
TridentProcessor
- All Known Implementing Classes:
AggregateProcessor
,BridgeReceiver
,EachProcessor
,MapProcessor
,MultiReducerProcessor
,PartitionPersistProcessor
,ProjectedProcessor
,StateQueryProcessor
,WindowTridentProcessor
public interface TupleReceiver
-
Method Summary
Modifier and TypeMethodDescriptionvoid
execute
(ProcessorContext processorContext, String streamId, TridentTuple tuple) void
flush()
-
Method Details
-
execute
-
flush
void flush()
-