org.apache.crunch.impl.mr.collect
Class DoCollectionImpl<S>

java.lang.Object
  org.apache.crunch.impl.mr.collect.PCollectionImpl<S>
      org.apache.crunch.impl.mr.collect.DoCollectionImpl<S>

All Implemented Interfaces:

PCollection<S>

public class DoCollectionImpl<S>
extends PCollectionImpl<S>

Nested Class Summary

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

PCollectionImpl.Visitor

Method Summary

DoNode	createDoNode()
List<PCollectionImpl<?>>	getParents()
PType<S>	getPType() Returns the PType of this PCollection.

Methods inherited from class org.apache.crunch.impl.mr.collect.PCollectionImpl

accept, by, by, count, filter, filter, getDepth, getMaterializedAt, getName, getOnlyParent, getPipeline, getSize, getTypeFamily, materialize, materializeAt, max, min, parallelDo, parallelDo, parallelDo, parallelDo, sample, sample, sort, toString, union, write

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

getPType

public PType<S> getPType()

Description copied from interface: PCollection

Returns the PType of this PCollection.

getParents

public List<PCollectionImpl<?>> getParents()

Specified by:

getParents in class PCollectionImpl<S>

createDoNode

public DoNode createDoNode()

Specified by:

createDoNode in class PCollectionImpl<S>