storm.trident.state
Class CombinerValueUpdater

java.lang.Object
  storm.trident.state.CombinerValueUpdater

All Implemented Interfaces:

ValueUpdater<java.lang.Object>

public class CombinerValueUpdater
extends java.lang.Object
implements ValueUpdater<java.lang.Object>

Constructor Summary

CombinerValueUpdater(CombinerAggregator agg, java.lang.Object arg)

Method Summary

java.lang.Object

update(java.lang.Object stored)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CombinerValueUpdater

public CombinerValueUpdater(CombinerAggregator agg,
                            java.lang.Object arg)

Method Detail

update

public java.lang.Object update(java.lang.Object stored)

Specified by:

update in interface ValueUpdater<java.lang.Object>