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

org.apache.crunch
Class CombineFn.LastNAggregator<V>

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

public static class CombineFn.LastNAggregator<V>
extends Object
implements CombineFn.Aggregator<V>

See Also:
Serialized Form

Constructor Summary
CombineFn.LastNAggregator(int arity)
           
 
Method Summary
 void reset()
          Clears the internal state of this Aggregator and prepares it for the values associated with the next key.
 Iterable<V> results()
          Returns the current aggregated state of this instance.
 void update(V 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.LastNAggregator

public CombineFn.LastNAggregator(int arity)
Method Detail

reset

public void reset()
Description copied from interface: CombineFn.Aggregator
Clears the internal state of this Aggregator and prepares it for the values associated with the next key.

Specified by:
reset in interface CombineFn.Aggregator<V>

update

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

Specified by:
update in interface CombineFn.Aggregator<V>

results

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

Specified by:
results in interface CombineFn.Aggregator<V>


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