Package org.apache.storm.trident.state

Class CombinerValueUpdater

java.lang.Object

org.apache.storm.trident.state.CombinerValueUpdater

All Implemented Interfaces:

ValueUpdater<Object>

public class CombinerValueUpdater
extends Object
implements ValueUpdater<Object>

Constructor Summary

Constructors

Constructor	Description
CombinerValueUpdater(CombinerAggregator agg, Object arg)

Method Summary

Modifier and Type	Method	Description
CombinerAggregator	getAgg()
Object	getArg()
Object	update(Object stored)

Methods inherited from class java.lang.Object

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

Constructor Details

CombinerValueUpdater

public CombinerValueUpdater(CombinerAggregator agg,
 Object arg)

Method Details

update

public Object update(Object stored)

Specified by:

update in interface ValueUpdater<Object>

getArg

public Object getArg()

getAgg

public CombinerAggregator getAgg()