Methods in org.apache.crunch.lib with parameters of type PGroupedTable |
static
|
PTables.mapValues(PGroupedTable<K,U> ptable,
MapFn<Iterable<U>,V> mapFn,
PType<V> ptype)
An analogue of the mapValues function for PGroupedTable<K, U> collections. |
static
|
PTables.mapValues(String name,
PGroupedTable<K,U> ptable,
MapFn<Iterable<U>,V> mapFn,
PType<V> ptype)
An analogue of the mapValues function for PGroupedTable<K, U> collections. |
static
<K1,V1,K2 extends org.apache.hadoop.io.Writable,V2 extends org.apache.hadoop.io.Writable>
PTable<K2,V2> |
|
Mapreduce.reduce(PGroupedTable<K1,V1> input,
Class<? extends org.apache.hadoop.mapreduce.Reducer<K1,V1,K2,V2>> reducerClass,
Class<K2> keyClass,
Class<V2> valueClass)
|
static
<K1,V1,K2 extends org.apache.hadoop.io.Writable,V2 extends org.apache.hadoop.io.Writable>
PTable<K2,V2> |
|
Mapred.reduce(PGroupedTable<K1,V1> input,
Class<? extends org.apache.hadoop.mapred.Reducer<K1,V1,K2,V2>> reducerClass,
Class<K2> keyClass,
Class<V2> valueClass)
|