storm.trident.operation.impl

Class CombinerAggStateUpdater

java.lang.Object

storm.trident.operation.impl.CombinerAggStateUpdater

All Implemented Interfaces:

Serializable, Operation, StateUpdater<Snapshottable>

public class CombinerAggStateUpdater
extends Object
implements StateUpdater<Snapshottable>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CombinerAggStateUpdater(CombinerAggregator agg)

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup()
void	prepare(Map conf, TridentOperationContext context)
void	updateState(Snapshottable state, 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

CombinerAggStateUpdater

public CombinerAggStateUpdater(CombinerAggregator agg)

Method Detail

updateState

public void updateState(Snapshottable state,
               List<TridentTuple> tuples,
               TridentCollector collector)

Specified by:

updateState in interface StateUpdater<Snapshottable>

prepare

public void prepare(Map conf,
           TridentOperationContext context)

Specified by:

prepare in interface Operation

cleanup

public void cleanup()

Specified by:

cleanup in interface Operation