Uses of Interface
org.apache.storm.trident.planner.TridentProcessor
-
Packages that use TridentProcessor Package Description org.apache.storm.trident.planner org.apache.storm.trident.planner.processor org.apache.storm.trident.windowing -
-
Uses of TridentProcessor in org.apache.storm.trident.planner
Fields in org.apache.storm.trident.planner declared as TridentProcessor Modifier and Type Field Description TridentProcessorProcessorNode. processorMethods in org.apache.storm.trident.planner with parameters of type TridentProcessor Modifier and Type Method Description voidSubtopologyBolt.InitialReceiver. addReceiver(TridentProcessor p)Constructors in org.apache.storm.trident.planner with parameters of type TridentProcessor Constructor Description ProcessorNode(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 TridentProcessor Modifier and Type Class Description classAggregateProcessorclassEachProcessorclassMapProcessorProcessor for executingStream.map(MapFunction)andStream.flatMap(FlatMapFunction)functions.classMultiReducerProcessorclassPartitionPersistProcessorclassProjectedProcessorclassStateQueryProcessor -
Uses of TridentProcessor in org.apache.storm.trident.windowing
Classes in org.apache.storm.trident.windowing that implement TridentProcessor Modifier and Type Class Description classWindowTridentProcessorTridentProcessorimplementation for windowing operations on trident stream.
-