Uses of Interface
org.apache.storm.trident.planner.TridentProcessor
Packages that use TridentProcessor
Package
Description
-
Uses of TridentProcessor in org.apache.storm.trident.planner
Fields in org.apache.storm.trident.planner declared as TridentProcessorMethods in org.apache.storm.trident.planner with parameters of type TridentProcessorModifier and TypeMethodDescriptionvoid
SubtopologyBolt.InitialReceiver.addReceiver
(TridentProcessor p) Constructors in org.apache.storm.trident.planner with parameters of type TridentProcessorModifierConstructorDescriptionProcessorNode
(String streamId, String name, Fields allOutputFields, Fields selfOutFields, TridentProcessor processor) -
Uses of TridentProcessor in org.apache.storm.trident.planner.processor
Classes in org.apache.storm.trident.planner.processor that implement TridentProcessorModifier 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
Classes in org.apache.storm.trident.windowing that implement TridentProcessorModifier and TypeClassDescriptionclass
TridentProcessor
implementation for windowing operations on trident stream.