storm.trident.planner.processor
Class PartitionPersistProcessor

java.lang.Object
  extended by storm.trident.planner.processor.PartitionPersistProcessor
All Implemented Interfaces:
java.io.Serializable, TridentProcessor, TupleReceiver

public class PartitionPersistProcessor
extends java.lang.Object
implements TridentProcessor

See Also:
Serialized Form

Constructor Summary
PartitionPersistProcessor(java.lang.String stateId, Fields inputFields, StateUpdater updater)
           
 
Method Summary
 void cleanup()
           
 void execute(ProcessorContext processorContext, java.lang.String streamId, TridentTuple tuple)
           
 void finishBatch(ProcessorContext processorContext)
           
 TridentTuple.Factory getOutputFactory()
           
 void prepare(java.util.Map 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

PartitionPersistProcessor

public PartitionPersistProcessor(java.lang.String stateId,
                                 Fields inputFields,
                                 StateUpdater updater)
Method Detail

prepare

public void prepare(java.util.Map conf,
                    TopologyContext context,
                    TridentContext tridentContext)
Specified by:
prepare in interface TridentProcessor

cleanup

public void cleanup()
Specified by:
cleanup in interface TridentProcessor

startBatch

public void startBatch(ProcessorContext processorContext)
Specified by:
startBatch in interface TridentProcessor

execute

public void execute(ProcessorContext processorContext,
                    java.lang.String streamId,
                    TridentTuple tuple)
Specified by:
execute in interface TupleReceiver

finishBatch

public void finishBatch(ProcessorContext processorContext)
Specified by:
finishBatch in interface TridentProcessor

getOutputFactory

public TridentTuple.Factory getOutputFactory()
Specified by:
getOutputFactory in interface TridentProcessor