|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
---|
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 . |
PTable<K,V> |
PGroupedTable.combineValues(CombineFn<K,V> combineFn,
CombineFn<K,V> reduceFn)
Combines and reduces the values of this grouping using the given CombineFn instances. |
PTable<K,V> |
PGroupedTable.combineValues(CombineFn<K,V> combineFn,
CombineFn<K,V> reduceFn)
Combines and reduces the values of this grouping using the given CombineFn instances. |
Uses of CombineFn in org.apache.crunch.fn |
---|
Methods in org.apache.crunch.fn that return CombineFn | ||
---|---|---|
static
|
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>
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |