Package org.apache.storm.trident.planner

# Interface TridentProcessor

All Superinterfaces:
  `Serializable`, `TupleReceiver`

All Known Implementing Classes:
  `AggregateProcessor`, `EachProcessor`, `MapProcessor`, `MultiReducerProcessor`, `PartitionPersistProcessor`, `ProjectedProcessor`, `StateQueryProcessor`, `WindowTridentProcessor`

public interface TridentProcessor extends Serializable, TupleReceiver

- ## Method Summary

  Modifier and Type
  Method
  Description
  `void`
  `cleanup()`
  `void`
  `finishBatch(ProcessorContext processorContext)`
  `TridentTuple.Factory`
  `getOutputFactory()`
  `void`
  `prepare(Map<String,Object> conf, TopologyContext context, TridentContext tridentContext)`
  `void`
  `startBatch(ProcessorContext processorContext)`

  ### Methods inherited from interface org.apache.storm.trident.planner.TupleReceiver

  `execute, flush`

- ## Method Details

  - ### prepare

    void prepare(Map<String,Object> conf, TopologyContext context, TridentContext tridentContext)

  - ### cleanup

    void cleanup()

  - ### startBatch

    void startBatch(ProcessorContext processorContext)

  - ### finishBatch

    void finishBatch(ProcessorContext processorContext)

  - ### getOutputFactory

    TridentTuple.Factory getOutputFactory()