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

Method Details

execute

void execute(ProcessorContext processorContext,
 String streamId,
 TridentTuple tuple)

flush

void flush()