|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use BaseGroupedTable | |
---|---|
org.apache.crunch.impl.dist.collect | |
org.apache.crunch.impl.mr.collect | |
org.apache.crunch.impl.spark.collect |
Uses of BaseGroupedTable in org.apache.crunch.impl.dist.collect |
---|
Methods in org.apache.crunch.impl.dist.collect that return BaseGroupedTable | ||
---|---|---|
|
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)
|
Methods in org.apache.crunch.impl.dist.collect with parameters of type BaseGroupedTable | |
---|---|
void |
PCollectionImpl.Visitor.visitGroupedTable(BaseGroupedTable<?,?> collection)
|
Uses of BaseGroupedTable in org.apache.crunch.impl.mr.collect |
---|
Subclasses of BaseGroupedTable in org.apache.crunch.impl.mr.collect | |
---|---|
class |
PGroupedTableImpl<K,V>
|
Methods in org.apache.crunch.impl.mr.collect that return BaseGroupedTable | ||
---|---|---|
|
MRCollectionFactory.createGroupedTable(PTableBase<K,V> parent,
GroupingOptions groupingOptions)
|
Uses of BaseGroupedTable in org.apache.crunch.impl.spark.collect |
---|
Methods in org.apache.crunch.impl.spark.collect that return BaseGroupedTable | ||
---|---|---|
|
SparkCollectFactory.createGroupedTable(PTableBase<K,V> parent,
GroupingOptions groupingOptions)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |