storm.trident.planner
Interface TupleReceiver

All Known Subinterfaces:

TridentProcessor

All Known Implementing Classes:

AggregateProcessor, BridgeReceiver, EachProcessor, MultiReducerProcessor, PartitionPersistProcessor, ProjectedProcessor, StateQueryProcessor

public interface TupleReceiver

Method Summary

void	execute(ProcessorContext processorContext, java.lang.String streamId, TridentTuple tuple)

Method Detail

execute

void execute(ProcessorContext processorContext,
             java.lang.String streamId,
             TridentTuple tuple)