| 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.
|
| org.apache.crunch.impl.spark | |
| org.apache.crunch.util |
An assorted set of utilities.
|
| Modifier and Type | Method and Description |
|---|---|
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. |
| Modifier and Type | Method and Description |
|---|---|
PipelineExecution |
MemPipeline.runAsync() |
| Modifier and Type | Interface and Description |
|---|---|
interface |
MRPipelineExecution |
| Modifier and Type | Class and Description |
|---|---|
class |
SparkRuntime |
| Modifier and Type | Method and Description |
|---|---|
PipelineExecution |
SparkPipeline.runAsync() |
| Modifier and Type | Method and Description |
|---|---|
PipelineExecution |
CrunchTool.runAsync() |
Copyright © 2015 The Apache Software Foundation. All Rights Reserved.