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.dist
org.apache.crunch.impl.dist.collect
org.apache.crunch.io	Data input and output for Pipelines.
org.apache.crunch.util	An assorted set of utilities.

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.
SourceTarget<T>	SourceTarget.conf(String key, String value) Adds the given key-value pair to the Configuration instance(s) that are used to read and write this SourceTarget<T>.

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

Set<SourceTarget<?>>	ReadableData.getSourceTargets()
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) Deprecated.
ParallelDoOptions.Builder	ParallelDoOptions.Builder.sourceTargets(SourceTarget<?>... sourceTargets)
GroupingOptions.Builder	GroupingOptions.Builder.sourceTargets(SourceTarget<?>... st)

Method parameters in org.apache.crunch with type arguments of type SourceTarget

ParallelDoOptions.Builder	ParallelDoOptions.Builder.sourceTargets(Collection<SourceTarget<?>> sourceTargets)
GroupingOptions.Builder	GroupingOptions.Builder.sourceTargets(Collection<SourceTarget<?>> st)

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

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

<T> SourceTarget<T>

DistributedPipeline.createIntermediateOutput(PType<T> ptype)

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

Methods in org.apache.crunch.impl.dist.collect that return SourceTarget

SourceTarget<S>

PCollectionImpl.getMaterializedAt()

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

Set<SourceTarget<?>>	PCollectionImpl.getTargetDependencies()
Set<SourceTarget<?>>	BaseGroupedTable.getTargetDependencies()

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

void	PCollectionImpl.materializeAt(SourceTarget<S> sourceTarget)

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 SourceTarget<org.apache.avro.generic.GenericData.Record>	At.avroFile(org.apache.hadoop.fs.Path path) Creates a SourceTarget<GenericData.Record> by reading the schema of the Avro file 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 SourceTarget<org.apache.avro.generic.GenericData.Record>	At.avroFile(org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf) Creates a SourceTarget<GenericData.Record> by reading the schema of the Avro file at the given path using the FileSystem information contained in the given Configuration instance.
static <T> SourceTarget<T>	At.avroFile(org.apache.hadoop.fs.Path path, PType<T> ptype) Creates a SourceTarget<T> instance from the Avro file(s) at the given Path.
static SourceTarget<org.apache.avro.generic.GenericData.Record>	At.avroFile(String pathName) Creates a SourceTarget<GenericData.Record> by reading the schema of the Avro file at the given path.
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> SourceTarget<T>	At.avroFile(String pathName, PType<T> ptype) 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.util

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

Set<SourceTarget<?>>	UnionReadableData.getSourceTargets()
Set<SourceTarget<?>>	DelegatingReadableData.getSourceTargets()