Uses of Interface
org.apache.storm.trident.planner.TridentProcessor
Package
Description
-
Uses of TridentProcessor in org.apache.storm.trident.planner
Modifier and TypeMethodDescriptionvoid
SubtopologyBolt.InitialReceiver.addReceiver
(TridentProcessor p) ModifierConstructorDescriptionProcessorNode
(String streamId, String name, Fields allOutputFields, Fields selfOutFields, TridentProcessor processor) -
Uses of TridentProcessor in org.apache.storm.trident.planner.processor
Modifier and TypeClassDescriptionclass
class
class
Processor for executingStream.map(MapFunction)
andStream.flatMap(FlatMapFunction)
functions.class
class
class
class
-
Uses of TridentProcessor in org.apache.storm.trident.windowing
Modifier and TypeClassDescriptionclass
TridentProcessor
implementation for windowing operations on trident stream.