This project has retired. For details please refer to its Attic page.

Uses of Interface
org.apache.crunch.Target

Packages that use Target

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.
org.apache.crunch.impl.spark
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 that return Target

Target

Target.outputConf(String key, String value) Adds the given key-value pair to the Configuration instance that is used to write this Target.

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.dist

Methods in org.apache.crunch.impl.dist with parameters of type Target

void	DistributedPipeline.write(PCollection<?> pcollection, Target target)
void	DistributedPipeline.write(PCollection<?> pcollection, Target target, Target.WriteMode writeMode)

Uses of Target in org.apache.crunch.impl.dist.collect

Methods in org.apache.crunch.impl.dist.collect with parameters of type Target

PTable<K,V>	PTableBase.write(Target target)
PCollection<S>	PCollectionImpl.write(Target target)
PTable<K,V>	PTableBase.write(Target target, Target.WriteMode writeMode)
PCollection<S>	PCollectionImpl.write(Target target, Target.WriteMode writeMode)

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.spark

Constructor parameters in org.apache.crunch.impl.spark with type arguments of type Target

SparkRuntime(SparkPipeline pipeline, org.apache.spark.api.java.JavaSparkContext sparkContext, org.apache.hadoop.conf.Configuration conf, Map<PCollectionImpl<?>,Set<Target>> outputTargets, Map<PCollectionImpl<?>,org.apache.crunch.materialize.MaterializableIterable> toMaterialize, Map<PCollection<?>,org.apache.spark.storage.StorageLevel> toCache)

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 <K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> Target	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 <K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> Target	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)