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 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 org.apache.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()