This project has retired. For details please refer to its Attic page.
CombineFn.TupleNAggregator (Apache Crunch 0.4.0-incubating API)

org.apache.crunch
Class CombineFn.TupleNAggregator

java.lang.Object
  extended by org.apache.crunch.CombineFn.TupleNAggregator
All Implemented Interfaces:
Serializable, CombineFn.Aggregator<TupleN>
Enclosing class:
CombineFn<S,T>

public static class CombineFn.TupleNAggregator
extends Object

See Also:
Serialized Form

Constructor Summary
CombineFn.TupleNAggregator(CombineFn.Aggregator<?>... aggregators)
           
 
Method Summary
 Iterable<TupleN> results()
          Returns the current aggregated state of this instance.
 void update(TupleN value)
          Incorporate the given value into the aggregate state maintained by this instance.
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CombineFn.TupleNAggregator

public CombineFn.TupleNAggregator(CombineFn.Aggregator<?>... aggregators)
Method Detail

update

public void update(TupleN value)
Description copied from interface: CombineFn.Aggregator
Incorporate the given value into the aggregate state maintained by this instance.


results

public Iterable<TupleN> results()
Description copied from interface: CombineFn.Aggregator
Returns the current aggregated state of this instance.



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