|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Target.WriteMode | |
---|---|
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. |
Uses of Target.WriteMode in org.apache.crunch |
---|
Methods in org.apache.crunch that return Target.WriteMode | |
---|---|
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. |
Methods in org.apache.crunch with parameters of type Target.WriteMode | |
---|---|
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. |
Uses of Target.WriteMode in org.apache.crunch.impl.mem |
---|
Methods in org.apache.crunch.impl.mem with parameters of type Target.WriteMode | |
---|---|
void |
MemPipeline.write(PCollection<?> collection,
Target target,
Target.WriteMode writeMode)
|
Uses of Target.WriteMode in org.apache.crunch.impl.mr |
---|
Methods in org.apache.crunch.impl.mr with parameters of type Target.WriteMode | |
---|---|
void |
MRPipeline.write(PCollection<?> pcollection,
Target target,
Target.WriteMode writeMode)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |