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

Uses of Class
org.apache.crunch.PipelineResult

Packages that use PipelineResult

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.mr.exec
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

static PipelineResult

PipelineResult.EMPTY

Methods in org.apache.crunch that return PipelineResult

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

PipelineResult

DistributedPipeline.done()

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

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

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

PipelineResult

MRPipeline.run()

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

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

PipelineResult	MRExecutor.get()
PipelineResult	MRExecutor.get(long timeout, TimeUnit unit)
PipelineResult	MRExecutor.getResult()

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

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

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

PipelineResult	CrunchTool.done()
PipelineResult	CrunchTool.run()