This project has retired. For details please refer to its
Attic page.
BaseInputCollection (Apache Crunch 0.9.0 API)
org.apache.crunch.impl.dist.collect
Class BaseInputCollection<S>
java.lang.Object
org.apache.crunch.impl.dist.collect.PCollectionImpl<S>
org.apache.crunch.impl.dist.collect.BaseInputCollection<S>
- All Implemented Interfaces:
- PCollection<S>
- Direct Known Subclasses:
- InputCollection, InputCollection
public class BaseInputCollection<S>
- extends PCollectionImpl<S>
Methods inherited from class org.apache.crunch.impl.dist.collect.PCollectionImpl |
accept, asCollection, asReadable, by, by, cache, cache, count, filter, filter, getChainingCollection, getDepth, getMaterializedAt, getName, getOnlyParent, getParallelDoOptions, getPipeline, getSize, getTargetDependencies, getTypeFamily, isBreakpoint, length, materialize, materializeAt, materializedData, max, min, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, setBreakpoint, toString, union, union, write, write |
source
protected final Source<S> source
BaseInputCollection
public BaseInputCollection(Source<S> source,
DistributedPipeline pipeline)
getReadableDataInternal
protected ReadableData<S> getReadableDataInternal()
- Specified by:
getReadableDataInternal
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
.
getSource
public Source<S> getSource()
getSizeInternal
protected long getSizeInternal()
- Specified by:
getSizeInternal
in class PCollectionImpl<S>
getParents
public List<PCollectionImpl<?>> getParents()
- Specified by:
getParents
in class PCollectionImpl<S>
getLastModifiedAt
public long getLastModifiedAt()
- Specified by:
getLastModifiedAt
in class PCollectionImpl<S>
equals
public boolean equals(Object obj)
- Overrides:
equals
in class Object
hashCode
public int hashCode()
- Overrides:
hashCode
in class Object
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.