Package org.apache.storm.trident.state

Class ReducerValueUpdater

java.lang.Object

org.apache.storm.trident.state.ReducerValueUpdater

All Implemented Interfaces:

ValueUpdater<Object>

public class ReducerValueUpdater
extends Object
implements ValueUpdater<Object>

Constructor Summary

Constructors

Constructor	Description
ReducerValueUpdater(ReducerAggregator agg, List<TridentTuple> tuples)

Method Summary

Modifier and Type	Method	Description
Object	update(Object stored)

Methods inherited from class java.lang.Object

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

Constructor Details

ReducerValueUpdater

public ReducerValueUpdater(ReducerAggregator agg,
 List<TridentTuple> tuples)

Method Details

update

public Object update(Object stored)

Specified by:

update in interface ValueUpdater<Object>