com.cloudera.crunch
Class CombineFn.QuadAggregator<A,B,C,D>

java.lang.Object
  com.cloudera.crunch.CombineFn.QuadAggregator<A,B,C,D>

All Implemented Interfaces:

CombineFn.Aggregator<Tuple4<A,B,C,D>>, Serializable

Enclosing class:

CombineFn<S,T>

public static class CombineFn.QuadAggregator<A,B,C,D>
extends Object

See Also:

Serialized Form

Constructor Summary

CombineFn.QuadAggregator(CombineFn.Aggregator<A> a1, CombineFn.Aggregator<B> a2, CombineFn.Aggregator<C> a3, CombineFn.Aggregator<D> a4)

Method Summary

Iterable<Tuple4<A,B,C,D>>	results() Returns the current aggregated state of this instance.
void	update(Tuple4<A,B,C,D> 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

Constructor Detail

CombineFn.QuadAggregator

public CombineFn.QuadAggregator(CombineFn.Aggregator<A> a1,
                                CombineFn.Aggregator<B> a2,
                                CombineFn.Aggregator<C> a3,
                                CombineFn.Aggregator<D> a4)

Method Detail

update

public void update(Tuple4<A,B,C,D> value)

Description copied from interface: CombineFn.Aggregator

Incorporate the given value into the aggregate state maintained by this instance.

results

public Iterable<Tuple4<A,B,C,D>> results()

Description copied from interface: CombineFn.Aggregator

Returns the current aggregated state of this instance.