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)

Method Detail

execute

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