|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use PipelineResult | |
---|---|
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.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.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.done()
|
PipelineResult |
MRPipeline.run()
|
Uses of PipelineResult in org.apache.crunch.util |
---|
Methods in org.apache.crunch.util that return PipelineResult | |
---|---|
PipelineResult |
CrunchTool.done()
|
PipelineResult |
CrunchTool.run()
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |