This project has retired. For details please refer to its Attic page.

org.apache.crunch
Interface PGroupedTable<K,V>

All Superinterfaces:

PCollection<Pair<K,Iterable<V>>>

All Known Implementing Classes:

PGroupedTableImpl

public interface PGroupedTable<K,V>
extends PCollection<Pair<K,Iterable<V>>>

The Crunch representation of a grouped PTable.

Method Summary

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

by, by, count, filter, filter, getName, getPipeline, getPType, getSize, getTypeFamily, materialize, max, min, parallelDo, parallelDo, parallelDo, parallelDo, sample, sample, sort, union, write

Method Detail

combineValues

PTable<K,V> combineValues(CombineFn<K,V> combineFn)

Combines the values of this grouping using the given CombineFn.

Parameters:

combineFn - The combiner function

Returns:

A PTable where each key has a single value

ungroup

PTable<K,V> ungroup()

Convert this grouping back into a multimap.

Returns:

an ungrouped version of the data in this PGroupedTable.