Uses of Class
org.apache.storm.trident.planner.ProcessorContext
Package
Description
-
Uses of ProcessorContext in org.apache.storm.trident.planner
Modifier and TypeMethodDescriptionvoid
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
Modifier and TypeMethodDescriptionvoid
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
Modifier and TypeMethodDescriptionvoid
WindowTridentProcessor.execute
(ProcessorContext processorContext, String streamId, TridentTuple tuple) void
WindowTridentProcessor.finishBatch
(ProcessorContext processorContext) void
WindowTridentProcessor.startBatch
(ProcessorContext processorContext)