org.apache.crunch
Class CombineFn.TupleNAggregator
java.lang.Object
org.apache.crunch.CombineFn.TupleNAggregator
- All Implemented Interfaces:
- Serializable, CombineFn.Aggregator<TupleN>
- Enclosing class:
- CombineFn<S,T>
public static class CombineFn.TupleNAggregator
- extends Object
- See Also:
- Serialized Form
Method Summary |
Iterable<TupleN> |
results()
Returns the current aggregated state of this instance. |
void |
update(TupleN value)
Incorporate the given value into the aggregate state maintained by this
instance. |
CombineFn.TupleNAggregator
public CombineFn.TupleNAggregator(CombineFn.Aggregator<?>... aggregators)
update
public void update(TupleN value)
- Description copied from interface:
CombineFn.Aggregator
- Incorporate the given value into the aggregate state maintained by this
instance.
results
public Iterable<TupleN> results()
- Description copied from interface:
CombineFn.Aggregator
- Returns the current aggregated state of this instance.
Copyright © 2012 The Apache Software Foundation. All Rights Reserved.