Package org.apache.storm.trident.planner.processor

Class Summary

Class	Description
AggregateProcessor
AppendCollector
EachProcessor
FreshCollector
MapProcessor	Processor for executing Stream.map(MapFunction) and Stream.flatMap(FlatMapFunction) functions.
MultiReducerProcessor
PartitionPersistProcessor
ProjectedProcessor
StateQueryProcessor
TridentContext