This project has retired. For details please refer to its Attic page.

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.