storm.trident.state.map
Class MapCombinerAggStateUpdater

java.lang.Object
  storm.trident.state.map.MapCombinerAggStateUpdater

All Implemented Interfaces:

java.io.Serializable, Operation, StateUpdater<MapState>

public class MapCombinerAggStateUpdater
extends java.lang.Object
implements StateUpdater<MapState>

See Also:

Serialized Form

Constructor Summary

MapCombinerAggStateUpdater(CombinerAggregator agg, Fields groupFields, Fields inputFields)

Method Summary

void	cleanup()
void	prepare(java.util.Map conf, TridentOperationContext context)
void	updateState(MapState map, 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

MapCombinerAggStateUpdater

public MapCombinerAggStateUpdater(CombinerAggregator agg,
                                  Fields groupFields,
                                  Fields inputFields)

Method Detail

updateState

public void updateState(MapState map,
                        java.util.List<TridentTuple> tuples,
                        TridentCollector collector)

Specified by:

updateState in interface StateUpdater<MapState>

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