Methods in org.apache.crunch that return CombineFn |
static
|
CombineFn.aggregator(CombineFn.Aggregator<V> aggregator)
|
static
|
CombineFn.aggregatorFactory(CombineFn.AggregatorFactory<V> aggregator)
|
static
|
CombineFn.FIRST_N(int n)
|
static
|
CombineFn.LAST_N(int n)
|
static
|
CombineFn.MAX_BIGINTS()
|
static
|
CombineFn.MAX_BIGINTS(int n)
|
static
|
CombineFn.MAX_DOUBLES()
|
static
|
CombineFn.MAX_DOUBLES(int n)
|
static
|
CombineFn.MAX_FLOATS()
|
static
|
CombineFn.MAX_FLOATS(int n)
|
static
|
CombineFn.MAX_INTS()
|
static
|
CombineFn.MAX_INTS(int n)
|
static
|
CombineFn.MAX_LONGS()
|
static
|
CombineFn.MAX_LONGS(int n)
|
static
|
CombineFn.MIN_BIGINTS()
|
static
|
CombineFn.MIN_BIGINTS(int n)
|
static
|
CombineFn.MIN_DOUBLES()
|
static
|
CombineFn.MIN_DOUBLES(int n)
|
static
|
CombineFn.MIN_FLOATS()
|
static
|
CombineFn.MIN_FLOATS(int n)
|
static
|
CombineFn.MIN_INTS()
|
static
|
CombineFn.MIN_INTS(int n)
|
static
|
CombineFn.MIN_LONGS()
|
static
|
CombineFn.MIN_LONGS(int n)
|
static
|
CombineFn.pairAggregator(CombineFn.AggregatorFactory<V1> a1,
CombineFn.AggregatorFactory<V2> a2)
|
static
|
CombineFn.quadAggregator(CombineFn.AggregatorFactory<A> a1,
CombineFn.AggregatorFactory<B> a2,
CombineFn.AggregatorFactory<C> a3,
CombineFn.AggregatorFactory<D> a4)
|
static
|
CombineFn.STRING_CONCAT(String separator,
boolean skipNull)
Used to concatenate strings, with a separator between each strings. |
static
|
CombineFn.STRING_CONCAT(String separator,
boolean skipNull,
long maxOutputLength,
long maxInputLength)
Used to concatenate strings, with a separator between each strings. |
static
|
CombineFn.SUM_BIGINTS()
|
static
|
CombineFn.SUM_DOUBLES()
|
static
|
CombineFn.SUM_FLOATS()
|
static
|
CombineFn.SUM_INTS()
|
static
|
CombineFn.SUM_LONGS()
|
static
|
CombineFn.tripAggregator(CombineFn.AggregatorFactory<A> a1,
CombineFn.AggregatorFactory<B> a2,
CombineFn.AggregatorFactory<C> a3)
|
static
|
CombineFn.tupleAggregator(CombineFn.AggregatorFactory<?>... factories)
|