|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of SourceTarget in org.apache.crunch |
---|
Methods in org.apache.crunch that return SourceTarget | ||
---|---|---|
|
Target.asSourceTarget(PType<T> ptype)
|
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.impl.mr.collect |
---|
Methods in org.apache.crunch.impl.mr.collect that return SourceTarget | |
---|---|
SourceTarget<S> |
PCollectionImpl.getMaterializedAt()
|
Methods in org.apache.crunch.impl.mr.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. |
Uses of SourceTarget in org.apache.crunch.io.avro |
---|
Classes in org.apache.crunch.io.avro that implement SourceTarget | |
---|---|
class |
AvroFileSourceTarget<T>
|
Methods in org.apache.crunch.io.avro that return SourceTarget | ||
---|---|---|
|
AvroFileTarget.asSourceTarget(PType<T> ptype)
|
Uses of SourceTarget in org.apache.crunch.io.hbase |
---|
Classes in org.apache.crunch.io.hbase that implement SourceTarget | |
---|---|
class |
HBaseSourceTarget
|
Methods in org.apache.crunch.io.hbase that return SourceTarget | ||
---|---|---|
|
HBaseTarget.asSourceTarget(PType<T> ptype)
|
Uses of SourceTarget in org.apache.crunch.io.impl |
---|
Classes in org.apache.crunch.io.impl that implement SourceTarget | |
---|---|
class |
ReadableSourcePathTargetImpl<T>
|
class |
ReadableSourceTargetImpl<T>
|
class |
SourcePathTargetImpl<T>
|
class |
SourceTargetImpl<T>
|
class |
TableSourcePathTargetImpl<K,V>
|
class |
TableSourceTargetImpl<K,V>
|
Methods in org.apache.crunch.io.impl that return SourceTarget | ||
---|---|---|
|
SourceTargetImpl.asSourceTarget(PType<S> ptype)
|
|
|
FileTargetImpl.asSourceTarget(PType<T> ptype)
|
Uses of SourceTarget in org.apache.crunch.io.seq |
---|
Classes in org.apache.crunch.io.seq that implement SourceTarget | |
---|---|
class |
SeqFileSourceTarget<T>
|
class |
SeqFileTableSourceTarget<K,V>
|
Methods in org.apache.crunch.io.seq that return SourceTarget | ||
---|---|---|
|
SeqFileTarget.asSourceTarget(PType<T> ptype)
|
Uses of SourceTarget in org.apache.crunch.io.text |
---|
Classes in org.apache.crunch.io.text that implement SourceTarget | |
---|---|
class |
TextFileSourceTarget<T>
|
Methods in org.apache.crunch.io.text that return SourceTarget | ||
---|---|---|
|
TextFileTarget.asSourceTarget(PType<T> ptype)
|
Uses of SourceTarget in org.apache.crunch.types |
---|
Methods in org.apache.crunch.types that return SourceTarget | |
---|---|
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 | |
---|---|
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 | |
---|---|
SourceTarget<T> |
WritableType.getDefaultFileSource(org.apache.hadoop.fs.Path path)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |