Uses of Class
storm.trident.planner.ProcessorContext

Packages that use ProcessorContext

Package	Description
storm.trident.planner
storm.trident.planner.processor

Uses of ProcessorContext in storm.trident.planner

Methods in storm.trident.planner with parameters of type ProcessorContext

Modifier and Type	Method and Description
void	BridgeReceiver.execute(ProcessorContext context, String streamId, TridentTuple tuple)
void	TupleReceiver.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	TridentProcessor.finishBatch(ProcessorContext processorContext)
void	SubtopologyBolt.InitialReceiver.receive(ProcessorContext context, Tuple tuple)
void	TridentProcessor.startBatch(ProcessorContext processorContext)

Uses of ProcessorContext in storm.trident.planner.processor

Methods in storm.trident.planner.processor with parameters of type ProcessorContext

Modifier and Type	Method and Description
void	StateQueryProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	PartitionPersistProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	MultiReducerProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	ProjectedProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	AggregateProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	EachProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	StateQueryProcessor.finishBatch(ProcessorContext processorContext)
void	PartitionPersistProcessor.finishBatch(ProcessorContext processorContext)
void	MultiReducerProcessor.finishBatch(ProcessorContext processorContext)
void	ProjectedProcessor.finishBatch(ProcessorContext processorContext)
void	AggregateProcessor.finishBatch(ProcessorContext processorContext)
void	EachProcessor.finishBatch(ProcessorContext processorContext)
void	FreshCollector.setContext(ProcessorContext pc)
void	AppendCollector.setContext(ProcessorContext pc, TridentTuple t)
void	StateQueryProcessor.startBatch(ProcessorContext processorContext)
void	PartitionPersistProcessor.startBatch(ProcessorContext processorContext)
void	MultiReducerProcessor.startBatch(ProcessorContext processorContext)
void	ProjectedProcessor.startBatch(ProcessorContext processorContext)
void	AggregateProcessor.startBatch(ProcessorContext processorContext)
void	EachProcessor.startBatch(ProcessorContext processorContext)