This project has retired. For details please refer to its Attic page.
Uses of Interface org.apache.crunch.PGroupedTable (Apache Crunch 0.10.0 API)

Uses of Interface
org.apache.crunch.PGroupedTable

Packages that use PGroupedTable
org.apache.crunch Client-facing API and core abstractions. 
org.apache.crunch.impl.dist.collect   
org.apache.crunch.impl.spark.collect   
org.apache.crunch.lib Joining, sorting, aggregating, and other commonly used functionality. 
 

Uses of PGroupedTable in org.apache.crunch
 

Methods in org.apache.crunch that return PGroupedTable
 PGroupedTable<K,V> PTable.groupByKey()
          Performs a grouping operation on the keys of this table.
 PGroupedTable<K,V> PTable.groupByKey(GroupingOptions options)
          Performs a grouping operation on the keys of this table, using the additional GroupingOptions to control how the grouping is executed.
 PGroupedTable<K,V> PTable.groupByKey(int numPartitions)
          Performs a grouping operation on the keys of this table, using the given number of partitions.
 

Uses of PGroupedTable in org.apache.crunch.impl.dist.collect
 

Classes in org.apache.crunch.impl.dist.collect that implement PGroupedTable
 class BaseGroupedTable<K,V>
           
 

Uses of PGroupedTable in org.apache.crunch.impl.spark.collect
 

Classes in org.apache.crunch.impl.spark.collect that implement PGroupedTable
 class PGroupedTableImpl<K,V>
           
 

Uses of PGroupedTable in org.apache.crunch.lib
 

Methods in org.apache.crunch.lib with parameters of type PGroupedTable
static
<K,U,V> PTable<K,V>
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
<K,U,V> PTable<K,V>
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)
           
 



Copyright © 2014 The Apache Software Foundation. All Rights Reserved.