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()