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 | 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 |
---|---|
void |
Target.handleExisting(Target.WriteMode writeMode,
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 |
MemPipeline.write(PCollection<?> collection,
Target target,
Target.WriteMode writeMode) |
Modifier and Type | Method and Description |
---|---|
void |
MRPipeline.write(PCollection<?> pcollection,
Target target,
Target.WriteMode writeMode) |
Copyright © 2013 The Apache Software Foundation. All Rights Reserved.