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

- ## Method Details

  - ### execute

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

  - ### flush

    void flush()