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

Uses of Interface
org.apache.crunch.Pipeline

Packages that use Pipeline

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.mem.collect
org.apache.crunch.impl.mr	A Pipeline implementation that runs on Hadoop MapReduce.
org.apache.crunch.impl.spark
org.apache.crunch.io.hbase
org.apache.crunch.materialize
org.apache.crunch.util	An assorted set of utilities.

Uses of Pipeline in org.apache.crunch

Methods in org.apache.crunch that return Pipeline

Pipeline

PCollection.getPipeline() Returns the Pipeline associated with this PCollection.

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

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

class

DistributedPipeline

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

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

class

MemPipeline

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

static Pipeline

MemPipeline.getInstance()

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

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

Pipeline

MemCollection.getPipeline()

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

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

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

class

SparkPipeline

Uses of Pipeline in org.apache.crunch.io.hbase

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

static PCollection<org.apache.hadoop.hbase.client.Result>	HFileUtils.scanHFiles(Pipeline pipeline, List<org.apache.hadoop.fs.Path> paths, org.apache.hadoop.hbase.client.Scan scan)
static PCollection<org.apache.hadoop.hbase.client.Result>	HFileUtils.scanHFiles(Pipeline pipeline, org.apache.hadoop.fs.Path path)
static PCollection<org.apache.hadoop.hbase.client.Result>	HFileUtils.scanHFiles(Pipeline pipeline, org.apache.hadoop.fs.Path path, org.apache.hadoop.hbase.client.Scan scan) Scans HFiles with filter conditions.

Uses of Pipeline in org.apache.crunch.materialize

Constructors in org.apache.crunch.materialize with parameters of type Pipeline

MaterializableIterable(Pipeline pipeline, ReadableSource<E> source)

Uses of Pipeline in org.apache.crunch.util

Methods in org.apache.crunch.util that return Pipeline

protected Pipeline

CrunchTool.getPipeline()