Uses of Interface
org.apache.crunch.SourceTarget

Packages that use SourceTarget

Package	Description
org.apache.crunch	Client-facing API and core abstractions.
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.types	Common functionality for business object serialization.
org.apache.crunch.types.avro	Business object serialization using Apache Avro.
org.apache.crunch.types.writable	Business object serialization using Hadoop's Writables framework.

Uses of SourceTarget in org.apache.crunch

Subinterfaces of SourceTarget in org.apache.crunch

Modifier and Type	Interface and Description
interface	TableSourceTarget<K,V> An interface for classes that implement both the TableSource and the Target interfaces.

Methods in org.apache.crunch that return SourceTarget

Modifier and Type	Method and Description
<T> SourceTarget<T>	Target.asSourceTarget(PType<T> ptype) Attempt to create the SourceTarget type that corresponds to this Target for the given PType, if possible.

Methods in org.apache.crunch that return types with arguments of type SourceTarget

Modifier and Type	Method and Description
Set<SourceTarget<?>>	ParallelDoOptions.getSourceTargets()

Methods in org.apache.crunch with parameters of type SourceTarget

Modifier and Type	Method and Description
ParallelDoOptions.Builder	ParallelDoOptions.Builder.sourceTargets(SourceTarget<?>... sourceTargets)

Uses of SourceTarget in org.apache.crunch.impl.mr

Methods in org.apache.crunch.impl.mr that return SourceTarget

Modifier and Type	Method and Description
<T> SourceTarget<T>	MRPipeline.createIntermediateOutput(PType<T> ptype)

Uses of SourceTarget in org.apache.crunch.io

Subinterfaces of SourceTarget in org.apache.crunch.io

Modifier and Type	Interface and Description
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 SourceTarget

Modifier and Type	Method and Description
static <T> SourceTarget<T>	At.avroFile(org.apache.hadoop.fs.Path path, AvroType<T> avroType) Creates a SourceTarget<T> instance from the Avro file(s) at the given Path.
static <T extends org.apache.avro.specific.SpecificRecord> SourceTarget<T>	At.avroFile(org.apache.hadoop.fs.Path path, Class<T> avroClass) Creates a SourceTarget<T> instance from the Avro file(s) at the given Path.
static <T> SourceTarget<T>	At.avroFile(String pathName, AvroType<T> avroType) Creates a SourceTarget<T> instance from the Avro file(s) at the given path name.
static <T extends org.apache.avro.specific.SpecificRecord> SourceTarget<T>	At.avroFile(String pathName, Class<T> avroClass) Creates a SourceTarget<T> instance from the Avro file(s) at the given path name.
static <T extends org.apache.hadoop.io.Writable> SourceTarget<T>	At.sequenceFile(org.apache.hadoop.fs.Path path, Class<T> valueClass) Creates a SourceTarget<T> instance from the SequenceFile(s) at the given Path from the value field of each key-value pair in the SequenceFile(s).
static <T> SourceTarget<T>	At.sequenceFile(org.apache.hadoop.fs.Path path, PType<T> ptype) Creates a SourceTarget<T> instance from the SequenceFile(s) at the given Path from the value field of each key-value pair in the SequenceFile(s).
static <T extends org.apache.hadoop.io.Writable> SourceTarget<T>	At.sequenceFile(String pathName, Class<T> valueClass) Creates a SourceTarget<T> instance from the SequenceFile(s) at the given path name from the value field of each key-value pair in the SequenceFile(s).
static <T> SourceTarget<T>	At.sequenceFile(String pathName, PType<T> ptype) Creates a SourceTarget<T> instance from the SequenceFile(s) at the given path name from the value field of each key-value pair in the SequenceFile(s).
static SourceTarget<String>	At.textFile(org.apache.hadoop.fs.Path path) Creates a SourceTarget<String> instance for the text file(s) at the given Path.
static <T> SourceTarget<T>	At.textFile(org.apache.hadoop.fs.Path path, PType<T> ptype) Creates a SourceTarget<T> instance for the text file(s) at the given Path using the provided PType<T> to convert the input text.
static SourceTarget<String>	At.textFile(String pathName) Creates a SourceTarget<String> instance for the text file(s) at the given path name.
static <T> SourceTarget<T>	At.textFile(String pathName, PType<T> ptype) Creates a SourceTarget<T> instance for the text file(s) at the given path name using the provided PType<T> to convert the input text.

Uses of SourceTarget in org.apache.crunch.types

Methods in org.apache.crunch.types that return SourceTarget

Modifier and Type	Method and Description
SourceTarget<T>	PType.getDefaultFileSource(org.apache.hadoop.fs.Path path) Returns a SourceTarget that is able to read/write data using the serialization format specified by this PType.
SourceTarget<Pair<K,Iterable<V>>>	PGroupedTableType.getDefaultFileSource(org.apache.hadoop.fs.Path path)

Uses of SourceTarget in org.apache.crunch.types.avro

Methods in org.apache.crunch.types.avro that return SourceTarget

Modifier and Type	Method and Description
SourceTarget<T>	AvroType.getDefaultFileSource(org.apache.hadoop.fs.Path path)

Uses of SourceTarget in org.apache.crunch.types.writable

Methods in org.apache.crunch.types.writable that return SourceTarget

Modifier and Type	Method and Description
SourceTarget<T>	WritableType.getDefaultFileSource(org.apache.hadoop.fs.Path path)