|
|||||||||
| 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 | ||||||||