|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Target in org.apache.crunch |
---|
Subinterfaces of Target in org.apache.crunch | |
---|---|
interface |
SourceTarget<T>
An interface for classes that implement both the Source and the
Target interfaces. |
Methods in org.apache.crunch with parameters of type Target | |
---|---|
void |
Pipeline.write(PCollection<?> collection,
Target target)
Write the given collection to the given target on the next pipeline run. |
PTable<K,V> |
PTable.write(Target target)
Writes this PTable to the given Target . |
PCollection<S> |
PCollection.write(Target target)
Write the contents of this PCollection to the given Target ,
using the storage format specified by the target. |
Uses of Target in org.apache.crunch.impl.mem |
---|
Methods in org.apache.crunch.impl.mem with parameters of type Target | |
---|---|
void |
MemPipeline.write(PCollection<?> collection,
Target target)
|
Uses of Target in org.apache.crunch.impl.mem.collect |
---|
Methods in org.apache.crunch.impl.mem.collect with parameters of type Target | |
---|---|
PTable<K,V> |
MemTable.write(Target target)
|
PCollection<S> |
MemCollection.write(Target target)
|
Uses of Target in org.apache.crunch.impl.mr |
---|
Methods in org.apache.crunch.impl.mr with parameters of type Target | |
---|---|
void |
MRPipeline.write(PCollection<?> pcollection,
Target target)
|
Uses of Target in org.apache.crunch.impl.mr.collect |
---|
Methods in org.apache.crunch.impl.mr.collect with parameters of type Target | |
---|---|
PTable<K,V> |
PTableBase.write(Target target)
|
PCollection<S> |
PCollectionImpl.write(Target target)
|
Uses of Target in org.apache.crunch.impl.mr.plan |
---|
Methods in org.apache.crunch.impl.mr.plan with parameters of type Target | |
---|---|
boolean |
MSCROutputHandler.configure(Target target,
PType<?> ptype)
|
void |
MSCROutputHandler.configureNode(DoNode node,
Target target)
|
Method parameters in org.apache.crunch.impl.mr.plan with type arguments of type Target | |
---|---|
void |
JobPrototype.addReducePaths(com.google.common.collect.HashMultimap<Target,org.apache.crunch.impl.mr.plan.NodePath> outputPaths)
|
static JobPrototype |
JobPrototype.createMapOnlyJob(com.google.common.collect.HashMultimap<Target,org.apache.crunch.impl.mr.plan.NodePath> mapNodePaths,
org.apache.hadoop.fs.Path workingPath)
|
Constructor parameters in org.apache.crunch.impl.mr.plan with type arguments of type Target | |
---|---|
MSCRPlanner(MRPipeline pipeline,
Map<PCollectionImpl<?>,Set<Target>> outputs)
|
Uses of Target in org.apache.crunch.io |
---|
Subinterfaces of Target in org.apache.crunch.io | |
---|---|
interface |
MapReduceTarget
|
interface |
PathTarget
|
interface |
ReadableSourceTarget<T>
An interface that indicates that a SourceTarget instance can be read
into the local client. |
Classes in org.apache.crunch.io that implement Target | |
---|---|
class |
PathTargetImpl
|
Methods in org.apache.crunch.io that return Target | |
---|---|
static Target |
To.avroFile(org.apache.hadoop.fs.Path path)
|
static Target |
To.avroFile(String pathName)
|
static Target |
To.formattedFile(org.apache.hadoop.fs.Path path,
Class<? extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat> formatClass)
|
static Target |
To.formattedFile(String pathName,
Class<? extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat> formatClass)
|
static Target |
To.sequenceFile(org.apache.hadoop.fs.Path path)
|
static Target |
To.sequenceFile(String pathName)
|
static Target |
To.textFile(org.apache.hadoop.fs.Path path)
|
static Target |
To.textFile(String pathName)
|
Methods in org.apache.crunch.io with parameters of type Target | |
---|---|
boolean |
OutputHandler.configure(Target target,
PType<?> ptype)
|
Uses of Target in org.apache.crunch.io.avro |
---|
Classes in org.apache.crunch.io.avro that implement Target | |
---|---|
class |
AvroFileSourceTarget<T>
|
class |
AvroFileTarget
|
Uses of Target in org.apache.crunch.io.hbase |
---|
Classes in org.apache.crunch.io.hbase that implement Target | |
---|---|
class |
HBaseSourceTarget
|
class |
HBaseTarget
|
Methods in org.apache.crunch.io.hbase that return Target | |
---|---|
static Target |
ToHBase.table(String table)
|
Uses of Target in org.apache.crunch.io.impl |
---|
Classes in org.apache.crunch.io.impl that implement Target | |
---|---|
class |
FileTargetImpl
|
class |
ReadableSourcePathTargetImpl<T>
|
class |
ReadableSourceTargetImpl<T>
|
class |
SourcePathTargetImpl<T>
|
class |
SourceTargetImpl<T>
|
class |
TableSourcePathTargetImpl<K,V>
|
class |
TableSourceTargetImpl<K,V>
|
Constructors in org.apache.crunch.io.impl with parameters of type Target | |
---|---|
ReadableSourceTargetImpl(ReadableSource<T> source,
Target target)
|
|
SourceTargetImpl(Source<T> source,
Target target)
|
|
TableSourceTargetImpl(TableSource<K,V> source,
Target target)
|
Uses of Target in org.apache.crunch.io.seq |
---|
Classes in org.apache.crunch.io.seq that implement Target | |
---|---|
class |
SeqFileSourceTarget<T>
|
class |
SeqFileTableSourceTarget<K,V>
|
class |
SeqFileTarget
|
Uses of Target in org.apache.crunch.io.text |
---|
Classes in org.apache.crunch.io.text that implement Target | |
---|---|
class |
TextFileSourceTarget<T>
|
class |
TextFileTarget
|
Uses of Target in org.apache.crunch.tool |
---|
Methods in org.apache.crunch.tool with parameters of type Target | |
---|---|
void |
CrunchTool.write(PCollection<?> pcollection,
Target target)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |