This project has retired. For details please refer to its Attic page.
Uses of Class org.apache.crunch.PipelineResult (Apache Crunch 0.9.0 API)

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()
           
 



Copyright © 2014 The Apache Software Foundation. All Rights Reserved.