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

Uses of Class
org.apache.crunch.impl.dist.DistributedPipeline

Packages that use DistributedPipeline

org.apache.crunch.impl.dist.collect
org.apache.crunch.impl.mr	A Pipeline implementation that runs on Hadoop MapReduce.
org.apache.crunch.impl.spark
org.apache.crunch.impl.spark.collect

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

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

DistributedPipeline

PCollectionImpl.getPipeline()

Methods in org.apache.crunch.impl.dist.collect with parameters of type DistributedPipeline

<S> BaseInputCollection<S>	PCollectionFactory.createInputCollection(Source<S> source, DistributedPipeline distributedPipeline)
<K,V> BaseInputTable<K,V>	PCollectionFactory.createInputTable(TableSource<K,V> source, DistributedPipeline distributedPipeline)

Constructors in org.apache.crunch.impl.dist.collect with parameters of type DistributedPipeline

BaseInputCollection(Source<S> source, DistributedPipeline pipeline)

BaseInputTable(TableSource<K,V> source, DistributedPipeline pipeline)

EmptyPCollection(DistributedPipeline pipeline, PType<T> ptype)

EmptyPTable(DistributedPipeline pipeline, PTableType<K,V> ptype)

PCollectionImpl(String name, DistributedPipeline pipeline)

PCollectionImpl(String name, DistributedPipeline pipeline, ParallelDoOptions doOptions)

PTableBase(String name, DistributedPipeline pipeline)

PTableBase(String name, DistributedPipeline pipeline, ParallelDoOptions options)

Uses of DistributedPipeline in org.apache.crunch.impl.mr

Subclasses of DistributedPipeline in org.apache.crunch.impl.mr

class

MRPipeline Pipeline implementation that is executed within Hadoop MapReduce.

Uses of DistributedPipeline in org.apache.crunch.impl.spark

Subclasses of DistributedPipeline in org.apache.crunch.impl.spark

class

SparkPipeline

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

Methods in org.apache.crunch.impl.spark.collect with parameters of type DistributedPipeline

<S> BaseInputCollection<S>	SparkCollectFactory.createInputCollection(Source<S> source, DistributedPipeline pipeline)
<K,V> BaseInputTable<K,V>	SparkCollectFactory.createInputTable(TableSource<K,V> source, DistributedPipeline pipeline)

Constructors in org.apache.crunch.impl.spark.collect with parameters of type DistributedPipeline

EmptyPCollection(DistributedPipeline pipeline, PType<T> ptype)

EmptyPTable(DistributedPipeline pipeline, PTableType<K,V> ptype)

InputTable(TableSource<K,V> source, DistributedPipeline pipeline)