org.apache.crunch
Interface CombineFn.Aggregator<T>

All Superinterfaces:
Serializable
All Known Implementing Classes:
CombineFn.FirstNAggregator, CombineFn.LastNAggregator, CombineFn.MaxBigInts, CombineFn.MaxDoubles, CombineFn.MaxFloats, CombineFn.MaxInts, CombineFn.MaxLongs, CombineFn.MaxNAggregator, CombineFn.MinBigInts, CombineFn.MinDoubles, CombineFn.MinFloats, CombineFn.MinInts, CombineFn.MinLongs, CombineFn.MinNAggregator, CombineFn.PairAggregator, CombineFn.QuadAggregator, CombineFn.StringConcatAggregator, CombineFn.SumBigInts, CombineFn.SumDoubles, CombineFn.SumFloats, CombineFn.SumInts, CombineFn.SumLongs, CombineFn.TripAggregator, CombineFn.TupleNAggregator
Enclosing class:
CombineFn<S,T>

public static interface CombineFn.Aggregator<T>
extends Serializable


Method Summary
 void reset()
          Clears the internal state of this Aggregator and prepares it for the values associated with the next key.
 Iterable<T> results()
          Returns the current aggregated state of this instance.
 void update(T value)
          Incorporate the given value into the aggregate state maintained by this instance.
 

Method Detail

reset

void reset()
Clears the internal state of this Aggregator and prepares it for the values associated with the next key.


update

void update(T value)
Incorporate the given value into the aggregate state maintained by this instance.


results

Iterable<T> results()
Returns the current aggregated state of this instance.



Copyright © 2012 The Apache Software Foundation. All Rights Reserved.