This project has retired. For details please refer to its Attic page.

Uses of Class
org.apache.crunch.impl.dist.collect.BaseInputTable

Packages that use BaseInputTable

org.apache.crunch.impl.dist.collect
org.apache.crunch.impl.spark.collect

Uses of BaseInputTable in org.apache.crunch.impl.dist.collect

Methods in org.apache.crunch.impl.dist.collect that return BaseInputTable

<K,V> BaseInputTable<K,V>

PCollectionFactory.createInputTable(TableSource<K,V> source, DistributedPipeline distributedPipeline, ParallelDoOptions doOpts)

Uses of BaseInputTable in org.apache.crunch.impl.spark.collect

Subclasses of BaseInputTable in org.apache.crunch.impl.spark.collect

class

InputTable<K,V>

Methods in org.apache.crunch.impl.spark.collect that return BaseInputTable

<K,V> BaseInputTable<K,V>

SparkCollectFactory.createInputTable(TableSource<K,V> source, DistributedPipeline pipeline, ParallelDoOptions doOpts)