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