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.SimpleAggregator, 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	initialize(org.apache.hadoop.conf.Configuration configuration) Perform any setup of this instance that is required prior to processing inputs.
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

initialize

void initialize(org.apache.hadoop.conf.Configuration configuration)

Perform any setup of this instance that is required prior to processing inputs.

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.