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	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

static class

CombineFn.AggregatorCombineFn<K,V> Deprecated. Use the Aggregators.toCombineFn(org.apache.crunch.Aggregator) adapter

Methods in org.apache.crunch that return CombineFn

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

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

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

static class

Aggregate.TopKCombineFn<K,V>