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

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

Copyright © 2021 The Apache Software Foundation. All rights reserved.