storm.trident.planner

Interface TridentProcessor

All Superinterfaces:

Serializable, TupleReceiver

All Known Implementing Classes:

AggregateProcessor, EachProcessor, MultiReducerProcessor, PartitionPersistProcessor, ProjectedProcessor, StateQueryProcessor

public interface TridentProcessor
extends Serializable, TupleReceiver

Method Summary

Methods

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

Methods inherited from interface storm.trident.planner.TupleReceiver

execute

Method Detail

prepare

void prepare(Map conf,
           TopologyContext context,
           TridentContext tridentContext)

cleanup

void cleanup()

startBatch

void startBatch(ProcessorContext processorContext)

finishBatch

void finishBatch(ProcessorContext processorContext)

getOutputFactory

TridentTuple.Factory getOutputFactory()