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