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

Methods

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)