|
|||||||||
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. |
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. |
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. |
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)
|
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)
|
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. |
Classes in org.apache.crunch.io that implement Target | |
---|---|
class |
PathTargetImpl
|
Methods in org.apache.crunch.io that return Target | |
---|---|
static Target |
To.avroFile(org.apache.hadoop.fs.Path path)
|
static Target |
To.avroFile(String pathName)
|
static Target |
To.formattedFile(org.apache.hadoop.fs.Path path,
Class<? extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat> formatClass)
|
static Target |
To.formattedFile(String pathName,
Class<? extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat> formatClass)
|
static Target |
To.sequenceFile(org.apache.hadoop.fs.Path path)
|
static Target |
To.sequenceFile(String pathName)
|
static Target |
To.textFile(org.apache.hadoop.fs.Path path)
|
static Target |
To.textFile(String pathName)
|
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 |