|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
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 | ||
---|---|---|
|
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 | ||
---|---|---|
|
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
|
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
|
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
|
At.avroFile(String pathName,
AvroType<T> avroType)
Creates a SourceTarget<T> instance from the Avro file(s) at the given path name. |
|
static
|
At.avroFile(String pathName,
Class<T> avroClass)
Creates a SourceTarget<T> instance from the Avro file(s) at the given path name. |
|
static
|
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
|
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
|
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
|
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
|
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
|
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. |
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |