|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface PGroupedTable<K,V>
The Crunch representation of a grouped PTable
.
Method Summary | |
---|---|
PTable<K,V> |
combineValues(Aggregator<V> aggregator)
Combine the values in each group using the given Aggregator . |
PTable<K,V> |
combineValues(CombineFn<K,V> combineFn)
Combines the values of this grouping using the given CombineFn . |
PTable<K,V> |
ungroup()
Convert this grouping back into a multimap. |
Methods inherited from interface org.apache.crunch.PCollection |
---|
asCollection, by, by, count, filter, filter, getName, getPipeline, getPType, getSize, getTypeFamily, length, materialize, max, min, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, union, union, write, write |
Method Detail |
---|
PTable<K,V> combineValues(CombineFn<K,V> combineFn)
CombineFn
.
combineFn
- The combiner function
PTable
where each key has a single valuePTable<K,V> combineValues(Aggregator<V> aggregator)
Aggregator
.
aggregator
- The function to use
PTable
where each group key maps to an aggregated
value. Group keys may be repeated if an aggregator returns
more than one value.PTable<K,V> ungroup()
PGroupedTable
.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |