This project has retired. For details please refer to its
Attic page.
BaseInputTable (Apache Crunch 0.9.0 API)
org.apache.crunch.impl.dist.collect
Class BaseInputTable<K,V>
java.lang.Object
org.apache.crunch.impl.dist.collect.PCollectionImpl<Pair<K,V>>
org.apache.crunch.impl.dist.collect.PTableBase<K,V>
org.apache.crunch.impl.dist.collect.BaseInputTable<K,V>
- All Implemented Interfaces:
- PCollection<Pair<K,V>>, PTable<K,V>
- Direct Known Subclasses:
- InputTable, InputTable
public class BaseInputTable<K,V>
- extends PTableBase<K,V>
Methods inherited from class org.apache.crunch.impl.dist.collect.PTableBase |
asMap, bottom, cache, cache, cogroup, collectValues, filter, filter, getKeyType, getValueType, groupByKey, groupByKey, groupByKey, join, keys, mapKeys, mapKeys, mapValues, mapValues, materializeToMap, top, union, union, values, write, write |
Methods inherited from class org.apache.crunch.impl.dist.collect.PCollectionImpl |
accept, asCollection, asReadable, by, by, count, 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 |
Methods inherited from interface org.apache.crunch.PCollection |
asCollection, asReadable, by, by, count, getName, getPipeline, getSize, getTypeFamily, length, materialize, max, min, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, union, union |
source
protected final TableSource<K,V> source
asCollection
protected final BaseInputCollection<Pair<K,V>> asCollection
BaseInputTable
public BaseInputTable(TableSource<K,V> source,
DistributedPipeline pipeline)
getSource
public TableSource<K,V> getSource()
getSizeInternal
protected long getSizeInternal()
- Specified by:
getSizeInternal
in class PCollectionImpl<Pair<K,V>>
getPTableType
public PTableType<K,V> getPTableType()
- Description copied from interface:
PTable
- Returns the
PTableType
of this PTable
.
getPType
public PType<Pair<K,V>> getPType()
- Description copied from interface:
PCollection
- Returns the
PType
of this PCollection
.
getParents
public List<PCollectionImpl<?>> getParents()
- Specified by:
getParents
in class PCollectionImpl<Pair<K,V>>
getReadableDataInternal
protected ReadableData<Pair<K,V>> getReadableDataInternal()
- Specified by:
getReadableDataInternal
in class PCollectionImpl<Pair<K,V>>
getLastModifiedAt
public long getLastModifiedAt()
- Specified by:
getLastModifiedAt
in class PCollectionImpl<Pair<K,V>>
acceptInternal
protected void acceptInternal(PCollectionImpl.Visitor visitor)
- Specified by:
acceptInternal
in class PCollectionImpl<Pair<K,V>>
hashCode
public int hashCode()
- Overrides:
hashCode
in class Object
equals
public boolean equals(Object other)
- Overrides:
equals
in class Object
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.