storm.trident.planner
Interface TridentProcessor

All Superinterfaces:
java.io.Serializable, TupleReceiver
All Known Implementing Classes:
AggregateProcessor, EachProcessor, MultiReducerProcessor, PartitionPersistProcessor, ProjectedProcessor, StateQueryProcessor

public interface TridentProcessor
extends java.io.Serializable, TupleReceiver


Method Summary
 void cleanup()
           
 void finishBatch(ProcessorContext processorContext)
           
 TridentTuple.Factory getOutputFactory()
           
 void prepare(java.util.Map conf, TopologyContext context, TridentContext tridentContext)
           
 void startBatch(ProcessorContext processorContext)
           
 
Methods inherited from interface storm.trident.planner.TupleReceiver
execute
 

Method Detail

prepare

void prepare(java.util.Map conf,
             TopologyContext context,
             TridentContext tridentContext)

cleanup

void cleanup()

startBatch

void startBatch(ProcessorContext processorContext)

finishBatch

void finishBatch(ProcessorContext processorContext)

getOutputFactory

TridentTuple.Factory getOutputFactory()