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

Method Detail

execute

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

flush

void flush()