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

Uses of Interface
org.apache.crunch.PipelineExecution

Packages that use PipelineExecution

org.apache.crunch	Client-facing API and core abstractions.
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
org.apache.crunch.util	An assorted set of utilities.

Uses of PipelineExecution in org.apache.crunch

Methods in org.apache.crunch that return PipelineExecution

PipelineExecution

Pipeline.runAsync() Constructs and starts a series of MapReduce jobs in order ot write data to the output targets, but returns a ListenableFuture to allow clients to control job execution.

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

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

PipelineExecution

MemPipeline.runAsync()

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

Subinterfaces of PipelineExecution in org.apache.crunch.impl.mr

interface

MRPipelineExecution

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

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

class

SparkRuntime

Methods in org.apache.crunch.impl.spark that return PipelineExecution

PipelineExecution

SparkPipeline.runAsync()

Uses of PipelineExecution in org.apache.crunch.util

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

PipelineExecution

CrunchTool.runAsync()