Package | Description |
---|---|
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.
|
Modifier and Type | Field and Description |
---|---|
static PipelineResult |
PipelineResult.EMPTY |
Modifier and Type | Method and Description |
---|---|
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 |
Pipeline.run()
Constructs and executes a series of MapReduce jobs in order to write data
to the output targets.
|
Modifier and Type | Method and Description |
---|---|
PipelineResult |
MemPipeline.done() |
PipelineResult |
MemPipeline.run() |
Modifier and Type | Method and Description |
---|---|
PipelineResult |
MRPipeline.done() |
PipelineResult |
MRPipeline.run() |
Copyright © 2013 The Apache Software Foundation. All Rights Reserved.