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)
-
-
-
Constructor Detail
-
ReducerValueUpdater
public ReducerValueUpdater(ReducerAggregator agg, List<TridentTuple> tuples)
-
-
Method Detail
-
update
public Object update(Object stored)
- Specified by:
update
in interfaceValueUpdater<Object>
-
-