This project has retired. For details please refer to its
Attic page.
CombineFn.SumBigInts (Apache Crunch 0.3.0-incubating API)
org.apache.crunch
Class CombineFn.SumBigInts
java.lang.Object
org.apache.crunch.CombineFn.SumBigInts
- All Implemented Interfaces:
- Serializable, CombineFn.Aggregator<BigInteger>
- Enclosing class:
- CombineFn<S,T>
public static class CombineFn.SumBigInts
- extends Object
- implements CombineFn.Aggregator<BigInteger>
- See Also:
- Serialized Form
Method Summary |
void |
reset()
Clears the internal state of this Aggregator and prepares it for the
values associated with the next key. |
Iterable<BigInteger> |
results()
Returns the current aggregated state of this instance. |
void |
update(BigInteger next)
Incorporate the given value into the aggregate state maintained by this
instance. |
CombineFn.SumBigInts
public CombineFn.SumBigInts()
reset
public void reset()
- Description copied from interface:
CombineFn.Aggregator
- Clears the internal state of this Aggregator and prepares it for the
values associated with the next key.
- Specified by:
reset
in interface CombineFn.Aggregator<BigInteger>
update
public void update(BigInteger next)
- Description copied from interface:
CombineFn.Aggregator
- Incorporate the given value into the aggregate state maintained by this
instance.
- Specified by:
update
in interface CombineFn.Aggregator<BigInteger>
results
public Iterable<BigInteger> results()
- Description copied from interface:
CombineFn.Aggregator
- Returns the current aggregated state of this instance.
- Specified by:
results
in interface CombineFn.Aggregator<BigInteger>
Copyright © 2012 The Apache Software Foundation. All Rights Reserved.