Uses of Class
org.apache.crunch.CombineFn

Packages that use CombineFn

Package	Description
org.apache.crunch	Client-facing API and core abstractions.
org.apache.crunch.fn	Commonly used functions for manipulating collections.
org.apache.crunch.lib	Joining, sorting, aggregating, and other commonly used functionality.

Uses of CombineFn in org.apache.crunch

Subclasses of CombineFn in org.apache.crunch

Modifier and Type	Class and Description
static class	CombineFn.AggregatorCombineFn<K,V> Deprecated. Use the Aggregators.toCombineFn(org.apache.crunch.Aggregator) adapter

Methods in org.apache.crunch that return CombineFn

Modifier and Type	Method and Description
static <K,V> CombineFn<K,V>	CombineFn.aggregator(CombineFn.Aggregator<V> aggregator) Deprecated. Use Aggregators.toCombineFn(Aggregator)
static <K,V> CombineFn<K,V>	CombineFn.aggregatorFactory(CombineFn.AggregatorFactory<V> aggregator) Deprecated. Use PGroupedTable.combineValues(Aggregator) which doesn't require a factory.
static <K,V> CombineFn<K,V>	CombineFn.FIRST_N(int n) Deprecated. Use Aggregators.FIRST_N(int)
static <K,V> CombineFn<K,V>	CombineFn.LAST_N(int n) Deprecated. Use Aggregators.LAST_N(int)
static <K> CombineFn<K,BigInteger>	CombineFn.MAX_BIGINTS() Deprecated. Use Aggregators.MAX_BIGINTS()
static <K> CombineFn<K,BigInteger>	CombineFn.MAX_BIGINTS(int n) Deprecated. Use Aggregators.MAX_BIGINTS(int)
static <K> CombineFn<K,Double>	CombineFn.MAX_DOUBLES() Deprecated. Use Aggregators.MAX_DOUBLES()
static <K> CombineFn<K,Double>	CombineFn.MAX_DOUBLES(int n) Deprecated. Use Aggregators.MAX_DOUBLES(int)
static <K> CombineFn<K,Float>	CombineFn.MAX_FLOATS() Deprecated. Use Aggregators.MAX_FLOATS()
static <K> CombineFn<K,Float>	CombineFn.MAX_FLOATS(int n) Deprecated. Use Aggregators.MAX_FLOATS(int)
static <K> CombineFn<K,Integer>	CombineFn.MAX_INTS() Deprecated. Use Aggregators.MAX_INTS()
static <K> CombineFn<K,Integer>	CombineFn.MAX_INTS(int n) Deprecated. Use Aggregators.MAX_INTS(int)
static <K> CombineFn<K,Long>	CombineFn.MAX_LONGS() Deprecated. Use Aggregators.MAX_LONGS()
static <K> CombineFn<K,Long>	CombineFn.MAX_LONGS(int n) Deprecated. Use Aggregators.MAX_LONGS(int)
static <K> CombineFn<K,BigInteger>	CombineFn.MIN_BIGINTS() Deprecated. Use Aggregators.MIN_BIGINTS()
static <K> CombineFn<K,BigInteger>	CombineFn.MIN_BIGINTS(int n) Deprecated. Use Aggregators.MIN_BIGINTS(int)
static <K> CombineFn<K,Double>	CombineFn.MIN_DOUBLES() Deprecated. Use Aggregators.MIN_DOUBLES()
static <K> CombineFn<K,Double>	CombineFn.MIN_DOUBLES(int n) Deprecated. Use Aggregators.MIN_DOUBLES(int)
static <K> CombineFn<K,Float>	CombineFn.MIN_FLOATS() Deprecated. Use Aggregators.MIN_FLOATS()
static <K> CombineFn<K,Float>	CombineFn.MIN_FLOATS(int n) Deprecated. Use Aggregators.MIN_FLOATS(int)
static <K> CombineFn<K,Integer>	CombineFn.MIN_INTS() Deprecated. Use Aggregators.MIN_INTS()
static <K> CombineFn<K,Integer>	CombineFn.MIN_INTS(int n) Deprecated. Use Aggregators.MIN_INTS(int)
static <K> CombineFn<K,Long>	CombineFn.MIN_LONGS() Deprecated. Use Aggregators.MIN_LONGS()
static <K> CombineFn<K,Long>	CombineFn.MIN_LONGS(int n) Deprecated. Use Aggregators.MIN_LONGS(int)
static <K,V1,V2> CombineFn<K,Pair<V1,V2>>	CombineFn.pairAggregator(CombineFn.AggregatorFactory<V1> a1, CombineFn.AggregatorFactory<V2> a2) Deprecated. Use Aggregators.pairAggregator(Aggregator, Aggregator)
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) Deprecated. Use Aggregators.quadAggregator(Aggregator, Aggregator, Aggregator, Aggregator)
static <K> CombineFn<K,String>	CombineFn.STRING_CONCAT(String separator, boolean skipNull) Deprecated. Use Aggregators.STRING_CONCAT(String, boolean)
static <K> CombineFn<K,String>	CombineFn.STRING_CONCAT(String separator, boolean skipNull, long maxOutputLength, long maxInputLength) Deprecated. Use Aggregators.STRING_CONCAT(String, boolean, long, long)
static <K> CombineFn<K,BigInteger>	CombineFn.SUM_BIGINTS() Deprecated. Use Aggregators.SUM_BIGINTS()
static <K> CombineFn<K,Double>	CombineFn.SUM_DOUBLES() Deprecated. Use Aggregators.SUM_DOUBLES()
static <K> CombineFn<K,Float>	CombineFn.SUM_FLOATS() Deprecated. Use Aggregators.SUM_FLOATS()
static <K> CombineFn<K,Integer>	CombineFn.SUM_INTS() Deprecated. Use Aggregators.SUM_INTS()
static <K> CombineFn<K,Long>	CombineFn.SUM_LONGS() Deprecated. Use Aggregators.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) Deprecated. Use Aggregators.tripAggregator(Aggregator, Aggregator, Aggregator)
static <K> CombineFn<K,TupleN>	CombineFn.tupleAggregator(CombineFn.AggregatorFactory<?>... factories) Deprecated. Use Aggregators.tupleAggregator(Aggregator...)

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

Modifier and Type	Method and Description
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.fn

Methods in org.apache.crunch.fn that return CombineFn

Modifier and Type	Method and Description
static <K,V> CombineFn<K,V>	Aggregators.toCombineFn(Aggregator<V> aggregator) Wrap a CombineFn adapter around the given aggregator.

Uses of CombineFn in org.apache.crunch.lib

Subclasses of CombineFn in org.apache.crunch.lib

Modifier and Type	Class and Description
static class	Aggregate.TopKCombineFn<K,V>