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 TypeMethodDescriptionvoidexecute(ProcessorContext processorContext, String streamId, TridentTuple tuple) voidflush()
-
Method Details
-
execute
-
flush
void flush()
-