|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
| Packages that use PipelineExecution | |
|---|---|
| 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 PipelineExecution in org.apache.crunch |
|---|
| Methods in org.apache.crunch that return PipelineExecution | |
|---|---|
PipelineExecution |
Pipeline.runAsync()
Constructs and starts a series of MapReduce jobs in order ot write data to the output targets, but returns a ListenableFuture to allow clients to control
job execution. |
| Uses of PipelineExecution in org.apache.crunch.impl.mem |
|---|
| Methods in org.apache.crunch.impl.mem that return PipelineExecution | |
|---|---|
PipelineExecution |
MemPipeline.runAsync()
|
| Uses of PipelineExecution in org.apache.crunch.impl.mr |
|---|
| Methods in org.apache.crunch.impl.mr that return PipelineExecution | |
|---|---|
PipelineExecution |
MRPipeline.runAsync()
|
| Uses of PipelineExecution in org.apache.crunch.util |
|---|
| Methods in org.apache.crunch.util that return PipelineExecution | |
|---|---|
PipelineExecution |
CrunchTool.runAsync()
|
|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||