TupleReceiver (Storm 2.7.1 API)

All Known Subinterfaces:

TridentProcessor

All Known Implementing Classes:

AggregateProcessor, BridgeReceiver, EachProcessor, MapProcessor, MultiReducerProcessor, PartitionPersistProcessor, ProjectedProcessor, StateQueryProcessor, WindowTridentProcessor
```
public interface TupleReceiver
```

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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()
```