com.cloudera.crunch.impl.mr.collect
Class UnionCollection<S>
java.lang.Object
com.cloudera.crunch.impl.mr.collect.PCollectionImpl<S>
com.cloudera.crunch.impl.mr.collect.UnionCollection<S>
- All Implemented Interfaces:
- PCollection<S>
public class UnionCollection<S>
- extends PCollectionImpl<S>
Methods inherited from class com.cloudera.crunch.impl.mr.collect.PCollectionImpl |
accept, count, filter, getDepth, getMaterializedAt, getName, getOnlyParent, getPipeline, getSize, getTypeFamily, materialize, materializeAt, max, min, parallelDo, parallelDo, parallelDo, parallelDo, sample, sample, sort, toString, union, write |
getSizeInternal
protected long getSizeInternal()
- Specified by:
getSizeInternal
in class PCollectionImpl<S>
acceptInternal
protected void acceptInternal(PCollectionImpl.Visitor visitor)
- Specified by:
acceptInternal
in class PCollectionImpl<S>
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>
Copyright © 2012. All Rights Reserved.