Uses of Interface
org.apache.crunch.Pipeline

Packages that use Pipeline

Package	Description
org.apache.crunch	Client-facing API and core abstractions.
org.apache.crunch.impl.dist
org.apache.crunch.impl.mem	In-memory Pipeline implementation for rapid prototyping and testing.
org.apache.crunch.impl.mr	A Pipeline implementation that runs on Hadoop MapReduce.
org.apache.crunch.impl.spark

Uses of Pipeline in org.apache.crunch

Methods in org.apache.crunch that return Pipeline

Modifier and Type	Method and Description
Pipeline	PCollection.getPipeline() Returns the Pipeline associated with this PCollection.

Methods in org.apache.crunch with parameters of type Pipeline

Modifier and Type	Method and Description
Output	PipelineCallable.generateOutput(Pipeline pipeline) Called by the Pipeline when this instance is registered with Pipeline#sequentialDo.

Uses of Pipeline in org.apache.crunch.impl.dist

Classes in org.apache.crunch.impl.dist that implement Pipeline

Modifier and Type	Class and Description
class	DistributedPipeline

Uses of Pipeline in org.apache.crunch.impl.mem

Classes in org.apache.crunch.impl.mem that implement Pipeline

Modifier and Type	Class and Description
class	MemPipeline

Methods in org.apache.crunch.impl.mem that return Pipeline

Modifier and Type	Method and Description
static Pipeline	MemPipeline.getInstance()

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

Classes in org.apache.crunch.impl.mr that implement Pipeline

Modifier and Type	Class and Description
class	MRPipeline Pipeline implementation that is executed within Hadoop MapReduce.

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

Classes in org.apache.crunch.impl.spark that implement Pipeline

Modifier and Type	Class and Description
class	SparkPipeline