| Package | Description |
|---|---|
| org.apache.crunch |
Client-facing API and core abstractions.
|
| org.apache.crunch.impl.dist | |
| org.apache.crunch.impl.dist.collect | |
| org.apache.crunch.impl.mem |
In-memory Pipeline implementation for rapid prototyping and testing.
|
| Modifier and Type | Method and Description |
|---|---|
static Target.WriteMode |
Target.WriteMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Target.WriteMode[] |
Target.WriteMode.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
Target.handleExisting(Target.WriteMode writeMode,
long lastModifiedAt,
org.apache.hadoop.conf.Configuration conf)
Apply the given
WriteMode to this Target instance. |
void |
Pipeline.write(PCollection<?> collection,
Target target,
Target.WriteMode writeMode)
Write the contents of the
PCollection to the given Target,
using the storage format specified by the target and the given
WriteMode for cases where the referenced Target
already exists. |
PTable<K,V> |
PTable.write(Target target,
Target.WriteMode writeMode)
Writes this
PTable to the given Target, using the
given Target.WriteMode to handle existing targets. |
PCollection<S> |
PCollection.write(Target target,
Target.WriteMode writeMode)
Write the contents of this
PCollection to the given Target,
using the given Target.WriteMode to handle existing
targets. |
| Modifier and Type | Method and Description |
|---|---|
void |
DistributedPipeline.write(PCollection<?> pcollection,
Target target,
Target.WriteMode writeMode) |
| Modifier and Type | Method and Description |
|---|---|
PTable<K,V> |
PTableBase.write(Target target,
Target.WriteMode writeMode) |
PCollection<S> |
PCollectionImpl.write(Target target,
Target.WriteMode writeMode) |
| Modifier and Type | Method and Description |
|---|---|
void |
MemPipeline.write(PCollection<?> collection,
Target target,
Target.WriteMode writeMode) |
Copyright © 2015 The Apache Software Foundation. All Rights Reserved.