Package org.apache.storm.trident.planner.processor
-
Class Summary Class Description AggregateProcessor AppendCollector EachProcessor FreshCollector MapProcessor Processor for executingStream.map(MapFunction)andStream.flatMap(FlatMapFunction)functions.MultiReducerProcessor PartitionPersistProcessor ProjectedProcessor StateQueryProcessor TridentContext