| Package | Description | 
|---|---|
| org.apache.crunch.impl.dist.collect | |
| org.apache.crunch.impl.spark.collect | 
| Modifier and Type | Method and Description | 
|---|---|
| <K,V> BaseGroupedTable<K,V> | PCollectionFactory. createGroupedTable(PTableBase<K,V> parent,
                  GroupingOptions groupingOptions) | 
| BaseGroupedTable<K,V> | PTableBase. groupByKey() | 
| BaseGroupedTable<K,V> | PTableBase. groupByKey(GroupingOptions groupingOptions) | 
| BaseGroupedTable<K,V> | PTableBase. groupByKey(int numReduceTasks) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | PCollectionImpl.Visitor. visitGroupedTable(BaseGroupedTable<?,?> collection) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | PGroupedTableImpl<K,V> | 
| Modifier and Type | Method and Description | 
|---|---|
| <K,V> BaseGroupedTable<K,V> | SparkCollectFactory. createGroupedTable(PTableBase<K,V> parent,
                  GroupingOptions groupingOptions) | 
Copyright © 2017 The Apache Software Foundation. All rights reserved.