This project has retired. For details please refer to its Attic page.

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

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.crunch.impl.dist.collect.PCollectionImpl

PCollectionImpl.Visitor

Field Summary

Fields inherited from class org.apache.crunch.impl.dist.collect.BaseGroupedTable

groupingOptions, parent, ptype

Fields inherited from class org.apache.crunch.impl.dist.collect.PCollectionImpl

doOptions, materializedAt, pipeline

Method Summary

void	accept(PCollectionImpl.Visitor visitor)
void	configureShuffle(org.apache.hadoop.mapreduce.Job job)
DoNode	createDoNode()
DoNode	getGroupingNode()

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 class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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

Method Detail

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()