Uses of Interface
com.cloudera.crunch.Pipeline

Packages that use Pipeline

com.cloudera.crunch
com.cloudera.crunch.impl.mem
com.cloudera.crunch.impl.mem.collect
com.cloudera.crunch.impl.mr
com.cloudera.crunch.impl.mr.collect
com.cloudera.crunch.materialize

Uses of Pipeline in com.cloudera.crunch

Methods in com.cloudera.crunch that return Pipeline

Pipeline

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

Uses of Pipeline in com.cloudera.crunch.impl.mem

Classes in com.cloudera.crunch.impl.mem that implement Pipeline

class

MemPipeline

Methods in com.cloudera.crunch.impl.mem that return Pipeline

static Pipeline

MemPipeline.getInstance()

Uses of Pipeline in com.cloudera.crunch.impl.mem.collect

Methods in com.cloudera.crunch.impl.mem.collect that return Pipeline

Pipeline

MemCollection.getPipeline()

Uses of Pipeline in com.cloudera.crunch.impl.mr

Classes in com.cloudera.crunch.impl.mr that implement Pipeline

class

MRPipeline

Uses of Pipeline in com.cloudera.crunch.impl.mr.collect

Methods in com.cloudera.crunch.impl.mr.collect that return Pipeline

Pipeline

PCollectionImpl.getPipeline()

Uses of Pipeline in com.cloudera.crunch.materialize

Constructors in com.cloudera.crunch.materialize with parameters of type Pipeline

MaterializableIterable(Pipeline pipeline, ReadableSourceTarget<E> source)