com.cloudera.crunch
Class CombineFn.MinNAggregator<V extends Comparable<V>>
java.lang.Object
com.cloudera.crunch.CombineFn.MinNAggregator<V>
- All Implemented Interfaces:
- CombineFn.Aggregator<V>, Serializable
- Enclosing class:
- CombineFn<S,T>
public static class CombineFn.MinNAggregator<V extends Comparable<V>>
- extends Object
- implements CombineFn.Aggregator<V>
- 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<V> |
results()
Returns the current aggregated state of this instance. |
void |
update(V value)
Incorporate the given value into the aggregate state maintained by this instance. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CombineFn.MinNAggregator
public CombineFn.MinNAggregator(int arity)
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<V extends Comparable<V>>
update
public void update(V value)
- 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<V extends Comparable<V>>
results
public Iterable<V> results()
- Description copied from interface:
CombineFn.Aggregator
- Returns the current aggregated state of this instance.
- Specified by:
results
in interface CombineFn.Aggregator<V extends Comparable<V>>
Copyright © 2012. All Rights Reserved.