|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Target | |
---|---|
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.io | Data input and output for Pipelines. |
org.apache.crunch.util | An assorted set of utilities. |
Uses of Target in org.apache.crunch |
---|
Subinterfaces of Target in org.apache.crunch | |
---|---|
interface |
SourceTarget<T>
An interface for classes that implement both the Source and the
Target interfaces. |
interface |
TableSourceTarget<K,V>
An interface for classes that implement both the TableSource and the
Target interfaces. |
Methods in org.apache.crunch with parameters of type Target | |
---|---|
void |
Pipeline.write(PCollection<?> collection,
Target target)
Write the given collection to the given target on the next pipeline run. |
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)
Writes this PTable to the given Target . |
PCollection<S> |
PCollection.write(Target target)
Write the contents of this PCollection to the given Target ,
using the storage format specified by the target. |
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 in org.apache.crunch.impl.mem |
---|
Methods in org.apache.crunch.impl.mem with parameters of type Target | |
---|---|
void |
MemPipeline.write(PCollection<?> collection,
Target target)
|
void |
MemPipeline.write(PCollection<?> collection,
Target target,
Target.WriteMode writeMode)
|
Uses of Target in org.apache.crunch.impl.mr |
---|
Methods in org.apache.crunch.impl.mr with parameters of type Target | |
---|---|
void |
MRPipeline.write(PCollection<?> pcollection,
Target target)
|
void |
MRPipeline.write(PCollection<?> pcollection,
Target target,
Target.WriteMode writeMode)
|
Uses of Target in org.apache.crunch.io |
---|
Subinterfaces of Target in org.apache.crunch.io | |
---|---|
interface |
MapReduceTarget
|
interface |
PathTarget
A target whose output goes to a given path on a file system. |
interface |
ReadableSourceTarget<T>
An interface that indicates that a SourceTarget instance can be read
into the local client. |
Methods in org.apache.crunch.io that return Target | ||
---|---|---|
static Target |
To.avroFile(org.apache.hadoop.fs.Path path)
Creates a Target at the given Path that writes data to
Avro files. |
|
static Target |
To.avroFile(String pathName)
Creates a Target at the given path name that writes data to
Avro files. |
|
static
|
To.formattedFile(org.apache.hadoop.fs.Path path,
Class<? extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<K,V>> formatClass)
Creates a Target at the given Path that writes data to
a custom FileOutputFormat . |
|
static
|
To.formattedFile(String pathName,
Class<? extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<K,V>> formatClass)
Creates a Target at the given path name that writes data to
a custom FileOutputFormat . |
|
static Target |
To.sequenceFile(org.apache.hadoop.fs.Path path)
Creates a Target at the given Path that writes data to
SequenceFiles. |
|
static Target |
To.sequenceFile(String pathName)
Creates a Target at the given path name that writes data to
SequenceFiles. |
|
static Target |
To.textFile(org.apache.hadoop.fs.Path path)
Creates a Target at the given Path that writes data to
text files. |
|
static Target |
To.textFile(String pathName)
Creates a Target at the given path name that writes data to
text files. |
Methods in org.apache.crunch.io with parameters of type Target | |
---|---|
boolean |
OutputHandler.configure(Target target,
PType<?> ptype)
|
Uses of Target in org.apache.crunch.util |
---|
Methods in org.apache.crunch.util with parameters of type Target | |
---|---|
void |
CrunchTool.write(PCollection<?> pcollection,
Target target)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |