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

Uses of Class
org.apache.crunch.CombineFn

Packages that use CombineFn

org.apache.crunch
org.apache.crunch.impl.mr.collect
org.apache.crunch.lib

Uses of CombineFn in org.apache.crunch

Subclasses of CombineFn in org.apache.crunch

static class

CombineFn.AggregatorCombineFn<K,V> A CombineFn that delegates all of the actual work to an Aggregator instance.

Methods in org.apache.crunch that return CombineFn

static <K,V> CombineFn<K,V>	CombineFn.aggregator(CombineFn.Aggregator<V> aggregator)
static <K,V> CombineFn<K,V>	CombineFn.aggregatorFactory(CombineFn.AggregatorFactory<V> aggregator)
static <K,V> CombineFn<K,V>	CombineFn.FIRST_N(int n)
static <K,V> CombineFn<K,V>	CombineFn.LAST_N(int n)
static <K> CombineFn<K,BigInteger>	CombineFn.MAX_BIGINTS()
static <K> CombineFn<K,BigInteger>	CombineFn.MAX_BIGINTS(int n)
static <K> CombineFn<K,Double>	CombineFn.MAX_DOUBLES()
static <K> CombineFn<K,Double>	CombineFn.MAX_DOUBLES(int n)
static <K> CombineFn<K,Float>	CombineFn.MAX_FLOATS()
static <K> CombineFn<K,Float>	CombineFn.MAX_FLOATS(int n)
static <K> CombineFn<K,Integer>	CombineFn.MAX_INTS()
static <K> CombineFn<K,Integer>	CombineFn.MAX_INTS(int n)
static <K> CombineFn<K,Long>	CombineFn.MAX_LONGS()
static <K> CombineFn<K,Long>	CombineFn.MAX_LONGS(int n)
static <K> CombineFn<K,BigInteger>	CombineFn.MIN_BIGINTS()
static <K> CombineFn<K,BigInteger>	CombineFn.MIN_BIGINTS(int n)
static <K> CombineFn<K,Double>	CombineFn.MIN_DOUBLES()
static <K> CombineFn<K,Double>	CombineFn.MIN_DOUBLES(int n)
static <K> CombineFn<K,Float>	CombineFn.MIN_FLOATS()
static <K> CombineFn<K,Float>	CombineFn.MIN_FLOATS(int n)
static <K> CombineFn<K,Integer>	CombineFn.MIN_INTS()
static <K> CombineFn<K,Integer>	CombineFn.MIN_INTS(int n)
static <K> CombineFn<K,Long>	CombineFn.MIN_LONGS()
static <K> CombineFn<K,Long>	CombineFn.MIN_LONGS(int n)
static <K,V1,V2> CombineFn<K,Pair<V1,V2>>	CombineFn.pairAggregator(CombineFn.AggregatorFactory<V1> a1, CombineFn.AggregatorFactory<V2> a2)
static <K,A,B,C,D> CombineFn<K,Tuple4<A,B,C,D>>	CombineFn.quadAggregator(CombineFn.AggregatorFactory<A> a1, CombineFn.AggregatorFactory<B> a2, CombineFn.AggregatorFactory<C> a3, CombineFn.AggregatorFactory<D> a4)
static <K> CombineFn<K,String>	CombineFn.STRING_CONCAT(String separator, boolean skipNull) Used to concatenate strings, with a separator between each strings.
static <K> CombineFn<K,String>	CombineFn.STRING_CONCAT(String separator, boolean skipNull, long maxOutputLength, long maxInputLength) Used to concatenate strings, with a separator between each strings.
static <K> CombineFn<K,BigInteger>	CombineFn.SUM_BIGINTS()
static <K> CombineFn<K,Double>	CombineFn.SUM_DOUBLES()
static <K> CombineFn<K,Float>	CombineFn.SUM_FLOATS()
static <K> CombineFn<K,Integer>	CombineFn.SUM_INTS()
static <K> CombineFn<K,Long>	CombineFn.SUM_LONGS()
static <K,A,B,C> CombineFn<K,Tuple3<A,B,C>>	CombineFn.tripAggregator(CombineFn.AggregatorFactory<A> a1, CombineFn.AggregatorFactory<B> a2, CombineFn.AggregatorFactory<C> a3)
static <K> CombineFn<K,TupleN>	CombineFn.tupleAggregator(CombineFn.AggregatorFactory<?>... factories)

Methods in org.apache.crunch with parameters of type CombineFn

PTable<K,V>

PGroupedTable.combineValues(CombineFn<K,V> combineFn) Combines the values of this grouping using the given CombineFn.

Uses of CombineFn in org.apache.crunch.impl.mr.collect

Methods in org.apache.crunch.impl.mr.collect with parameters of type CombineFn

PTable<K,V>

PGroupedTableImpl.combineValues(CombineFn<K,V> combineFn)

Uses of CombineFn in org.apache.crunch.lib

Subclasses of CombineFn in org.apache.crunch.lib

static class

Aggregate.TopKCombineFn<K,V>