Class MapProcessor

java.lang.Object
org.apache.storm.trident.planner.processor.MapProcessor
All Implemented Interfaces:
Serializable, TridentProcessor, TupleReceiver

public class MapProcessor extends Object implements TridentProcessor
Processor for executing Stream.map(MapFunction) and Stream.flatMap(FlatMapFunction) functions.
See Also: