This project has retired. For details please refer to its
Attic page.
PGroupedTableImpl (Apache Crunch 0.9.0 API)
org.apache.crunch.impl.mr.collect
Class PGroupedTableImpl<K,V>
java.lang.Object
org.apache.crunch.impl.dist.collect.PCollectionImpl<Pair<K,Iterable<V>>>
org.apache.crunch.impl.dist.collect.BaseGroupedTable<K,V>
org.apache.crunch.impl.mr.collect.PGroupedTableImpl<K,V>
- All Implemented Interfaces:
- MRCollection, PCollection<Pair<K,Iterable<V>>>, PGroupedTable<K,V>
public class PGroupedTableImpl<K,V>
- extends BaseGroupedTable<K,V>
- implements MRCollection
Methods inherited from class org.apache.crunch.impl.dist.collect.BaseGroupedTable |
acceptInternal, combineValues, combineValues, combineValues, combineValues, getChainingCollection, getGroupedTableType, getLastModifiedAt, getParents, getPType, getReadableDataInternal, getSizeInternal, getTargetDependencies, mapValues, mapValues, ungroup |
Methods inherited from class org.apache.crunch.impl.dist.collect.PCollectionImpl |
asCollection, asReadable, by, by, cache, cache, count, filter, filter, getDepth, getMaterializedAt, getName, getOnlyParent, getParallelDoOptions, getPipeline, getSize, getTypeFamily, isBreakpoint, length, materialize, materializeAt, materializedData, max, min, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, setBreakpoint, toString, union, union, write, write |
Methods inherited from interface org.apache.crunch.PCollection |
asCollection, asReadable, by, by, cache, cache, count, filter, filter, getName, getPipeline, getSize, getTypeFamily, length, materialize, max, min, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, union, union, write, write |
configureShuffle
public void configureShuffle(org.apache.hadoop.mapreduce.Job job)
accept
public void accept(PCollectionImpl.Visitor visitor)
- Overrides:
accept
in class PCollectionImpl<Pair<K,Iterable<V>>>
createDoNode
public DoNode createDoNode()
- Specified by:
createDoNode
in interface MRCollection
getGroupingNode
public DoNode getGroupingNode()
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.