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

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:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
MapProcessor(Fields inputFields, Function function)

Method Summary

Modifier and Type	Method	Description
void	cleanup()
void	execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
void	finishBatch(ProcessorContext processorContext)
void	flush()
TridentTuple.Factory	getOutputFactory()
void	prepare(Map<String,Object> conf, TopologyContext context, TridentContext tridentContext)
void	startBatch(ProcessorContext processorContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MapProcessor

public MapProcessor(Fields inputFields,
                    Function function)

Method Detail

prepare

public void prepare(Map<String,Object> conf,
                    TopologyContext context,
                    TridentContext tridentContext)

Specified by:

prepare in interface TridentProcessor

cleanup

public void cleanup()

Specified by:

cleanup in interface TridentProcessor

execute

public void execute(ProcessorContext processorContext,
                    String streamId,
                    TridentTuple tuple)

Specified by:

execute in interface TupleReceiver

flush

public void flush()

Specified by:

flush in interface TupleReceiver

startBatch

public void startBatch(ProcessorContext processorContext)

Specified by:

startBatch in interface TridentProcessor

finishBatch

public void finishBatch(ProcessorContext processorContext)

Specified by:

finishBatch in interface TridentProcessor

getOutputFactory

public TridentTuple.Factory getOutputFactory()

Specified by:

getOutputFactory in interface TridentProcessor