This project has retired. For details please refer to its
Attic page.
EmptyPTable (Apache Crunch 0.11.0 API)
org.apache.crunch.impl.spark.collect
Class EmptyPTable<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.EmptyPTable<K,V>
org.apache.crunch.impl.spark.collect.EmptyPTable<K,V>
- All Implemented Interfaces:
- SparkCollection, PCollection<Pair<K,V>>, PTable<K,V>
public class EmptyPTable<K,V>
- extends EmptyPTable<K,V>
- implements SparkCollection
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, aggregate, asCollection, asReadable, by, by, count, first, getDepth, getMaterializedAt, getName, getOnlyParent, getParallelDoOptions, getPipeline, getSize, getTargetDependencies, getTypeFamily, isBreakpoint, length, materialize, materializeAt, max, min, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, sequentialDo, setBreakpoint, toString, union, union |
Methods inherited from interface org.apache.crunch.PCollection |
aggregate, asCollection, asReadable, by, by, count, first, getName, getPipeline, getSize, getTypeFamily, length, materialize, max, min, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, parallelDo, sequentialDo, union, union |
EmptyPTable
public EmptyPTable(DistributedPipeline pipeline,
PTableType<K,V> ptype)
getJavaRDDLike
public org.apache.spark.api.java.JavaRDDLike<?,?> getJavaRDDLike(SparkRuntime runtime)
- Specified by:
getJavaRDDLike
in interface SparkCollection
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.