Uses of Class
org.apache.crunch.PipelineResult

Packages that use PipelineResult

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
org.apache.crunch.util	An assorted set of utilities.

Uses of PipelineResult in org.apache.crunch

Fields in org.apache.crunch declared as PipelineResult

Modifier and Type	Field and Description
static PipelineResult	PipelineResult.DONE
static PipelineResult	PipelineResult.EMPTY

Methods in org.apache.crunch that return PipelineResult

Modifier and Type	Method and Description
PipelineResult	Pipeline.done() Run any remaining jobs required to generate outputs and then clean up any intermediate data files that were created in this run or previous calls to run.
PipelineResult	PipelineExecution.getResult() Retrieve the result of a pipeline if it has been completed, otherwise null.
PipelineResult	Pipeline.run() Constructs and executes a series of MapReduce jobs in order to write data to the output targets.

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

Methods in org.apache.crunch.impl.dist that return PipelineResult

Modifier and Type	Method and Description
PipelineResult	DistributedPipeline.done()

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

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

Modifier and Type	Method and Description
PipelineResult	MemPipeline.done()
PipelineResult	MemPipeline.run()

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

Methods in org.apache.crunch.impl.mr that return PipelineResult

Modifier and Type	Method and Description
PipelineResult	MRPipeline.run()

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

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

Modifier and Type	Method and Description
PipelineResult	SparkPipeline.done()
PipelineResult	SparkRuntime.get()
PipelineResult	SparkRuntime.get(long timeout, TimeUnit unit)
PipelineResult	SparkRuntime.getResult()
PipelineResult	SparkPipeline.run()

Uses of PipelineResult in org.apache.crunch.util

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

Modifier and Type	Method and Description
PipelineResult	CrunchTool.done()
PipelineResult	CrunchTool.run()