Uses of Class
org.apache.storm.trident.planner.ProcessorContext

Packages that use ProcessorContext

Package	Description
org.apache.storm.trident.planner
org.apache.storm.trident.planner.processor
org.apache.storm.trident.windowing

Uses of ProcessorContext in org.apache.storm.trident.planner

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

Modifier and Type	Method	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 org.apache.storm.trident.planner.processor

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

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

Uses of ProcessorContext in org.apache.storm.trident.windowing

Methods in org.apache.storm.trident.windowing with parameters of type ProcessorContext

Modifier and Type	Method	Description
void	WindowTridentProcessor.execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	WindowTridentProcessor.finishBatch(ProcessorContext processorContext)
void	WindowTridentProcessor.startBatch(ProcessorContext processorContext)