Class ProjectedProcessor
- java.lang.Object
-
- org.apache.storm.trident.planner.processor.ProjectedProcessor
-
- All Implemented Interfaces:
Serializable,TridentProcessor,TupleReceiver
public class ProjectedProcessor extends Object implements TridentProcessor
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description ProjectedProcessor(Fields projectFields)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcleanup()voidexecute(ProcessorContext processorContext, String streamId, TridentTuple tuple)voidfinishBatch(ProcessorContext processorContext)voidflush()TridentTuple.FactorygetOutputFactory()voidprepare(Map<String,Object> conf, TopologyContext context, TridentContext tridentContext)voidstartBatch(ProcessorContext processorContext)
-
-
-
Constructor Detail
-
ProjectedProcessor
public ProjectedProcessor(Fields projectFields)
-
-
Method Detail
-
prepare
public void prepare(Map<String,Object> conf, TopologyContext context, TridentContext tridentContext)
- Specified by:
preparein interfaceTridentProcessor
-
cleanup
public void cleanup()
- Specified by:
cleanupin interfaceTridentProcessor
-
startBatch
public void startBatch(ProcessorContext processorContext)
- Specified by:
startBatchin interfaceTridentProcessor
-
execute
public void execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
- Specified by:
executein interfaceTupleReceiver
-
flush
public void flush()
- Specified by:
flushin interfaceTupleReceiver
-
finishBatch
public void finishBatch(ProcessorContext processorContext)
- Specified by:
finishBatchin interfaceTridentProcessor
-
getOutputFactory
public TridentTuple.Factory getOutputFactory()
- Specified by:
getOutputFactoryin interfaceTridentProcessor
-
-