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 © 2016 The Apache Software Foundation. All rights reserved.