storm.trident.operation.impl
Class ReducerAggStateUpdater

java.lang.Object
  extended by storm.trident.operation.impl.ReducerAggStateUpdater
All Implemented Interfaces:
java.io.Serializable, Operation, StateUpdater<Snapshottable>

public class ReducerAggStateUpdater
extends java.lang.Object
implements StateUpdater<Snapshottable>

See Also:
Serialized Form

Constructor Summary
ReducerAggStateUpdater(ReducerAggregator agg)
           
 
Method Summary
 void cleanup()
           
 void prepare(java.util.Map conf, TridentOperationContext context)
           
 void updateState(Snapshottable state, java.util.List<TridentTuple> tuples, TridentCollector collector)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ReducerAggStateUpdater

public ReducerAggStateUpdater(ReducerAggregator agg)
Method Detail

updateState

public void updateState(Snapshottable state,
                        java.util.List<TridentTuple> tuples,
                        TridentCollector collector)
Specified by:
updateState in interface StateUpdater<Snapshottable>

prepare

public void prepare(java.util.Map conf,
                    TridentOperationContext context)
Specified by:
prepare in interface Operation

cleanup

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