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

Uses of Interface
org.apache.crunch.SourceTarget

Packages that use SourceTarget

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.

Uses of SourceTarget in org.apache.crunch

Subinterfaces of SourceTarget in org.apache.crunch

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

<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

Set<SourceTarget<?>>	ParallelDoOptions.getSourceTargets()
Set<SourceTarget<?>>	GroupingOptions.getSourceTargets()

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

GroupingOptions.Builder	GroupingOptions.Builder.sourceTarget(SourceTarget<?> st)
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

<T> SourceTarget<T>

MRPipeline.createIntermediateOutput(PType<T> ptype)

Uses of SourceTarget in org.apache.crunch.io

Subinterfaces of SourceTarget in org.apache.crunch.io

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

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.