|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Pipeline in org.apache.crunch |
---|
Methods in org.apache.crunch that return Pipeline | |
---|---|
Pipeline |
PCollection.getPipeline()
Returns the Pipeline associated with this PCollection. |
Uses of Pipeline in org.apache.crunch.impl.mem |
---|
Classes in org.apache.crunch.impl.mem that implement Pipeline | |
---|---|
class |
MemPipeline
|
Methods in org.apache.crunch.impl.mem that return Pipeline | |
---|---|
static Pipeline |
MemPipeline.getInstance()
|
Uses of Pipeline in org.apache.crunch.impl.mem.collect |
---|
Methods in org.apache.crunch.impl.mem.collect that return Pipeline | |
---|---|
Pipeline |
MemCollection.getPipeline()
|
Uses of Pipeline in org.apache.crunch.impl.mr |
---|
Classes in org.apache.crunch.impl.mr that implement Pipeline | |
---|---|
class |
MRPipeline
|
Uses of Pipeline in org.apache.crunch.impl.mr.collect |
---|
Methods in org.apache.crunch.impl.mr.collect that return Pipeline | |
---|---|
Pipeline |
PCollectionImpl.getPipeline()
|
Uses of Pipeline in org.apache.crunch.impl.mr.plan |
---|
Methods in org.apache.crunch.impl.mr.plan with parameters of type Pipeline | |
---|---|
CrunchJob |
JobPrototype.getCrunchJob(Class<?> jarClass,
org.apache.hadoop.conf.Configuration conf,
Pipeline pipeline)
|
Uses of Pipeline in org.apache.crunch.materialize |
---|
Constructors in org.apache.crunch.materialize with parameters of type Pipeline | |
---|---|
MaterializableIterable(Pipeline pipeline,
ReadableSourceTarget<E> source)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |