|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use CombineFn | |
---|---|
com.cloudera.crunch | |
com.cloudera.crunch.impl.mr.collect | |
com.cloudera.crunch.lib |
Uses of CombineFn in com.cloudera.crunch |
---|
Subclasses of CombineFn in com.cloudera.crunch | |
---|---|
static class |
CombineFn.AggregatorCombineFn<K,V>
A CombineFn that delegates all of the actual work to an Aggregator
instance. |
Methods in com.cloudera.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.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)
|
Methods in com.cloudera.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 com.cloudera.crunch.impl.mr.collect |
---|
Methods in com.cloudera.crunch.impl.mr.collect with parameters of type CombineFn | |
---|---|
PTable<K,V> |
PGroupedTableImpl.combineValues(CombineFn<K,V> combineFn)
|
Uses of CombineFn in com.cloudera.crunch.lib |
---|
Subclasses of CombineFn in com.cloudera.crunch.lib | |
---|---|
static class |
Aggregate.TopKCombineFn<K,V>
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |