This project has retired. For details please refer to its Attic page.
Uses of Class org.apache.crunch.impl.dist.DistributedPipeline (Apache Crunch 0.10.0 API)

Uses of Class
org.apache.crunch.impl.dist.DistributedPipeline

Packages that use DistributedPipeline
org.apache.crunch.impl.dist.collect   
org.apache.crunch.impl.mr A Pipeline implementation that runs on Hadoop MapReduce. 
org.apache.crunch.impl.spark   
org.apache.crunch.impl.spark.collect   
 

Uses of DistributedPipeline in org.apache.crunch.impl.dist.collect
 

Methods in org.apache.crunch.impl.dist.collect that return DistributedPipeline
 DistributedPipeline PCollectionImpl.getPipeline()
           
 

Methods in org.apache.crunch.impl.dist.collect with parameters of type DistributedPipeline
<S> BaseInputCollection<S>
PCollectionFactory.createInputCollection(Source<S> source, DistributedPipeline distributedPipeline)
           
<K,V> BaseInputTable<K,V>
PCollectionFactory.createInputTable(TableSource<K,V> source, DistributedPipeline distributedPipeline)
           
 

Constructors in org.apache.crunch.impl.dist.collect with parameters of type DistributedPipeline
BaseInputCollection(Source<S> source, DistributedPipeline pipeline)
           
BaseInputTable(TableSource<K,V> source, DistributedPipeline pipeline)
           
EmptyPCollection(DistributedPipeline pipeline, PType<T> ptype)
           
EmptyPTable(DistributedPipeline pipeline, PTableType<K,V> ptype)
           
PCollectionImpl(String name, DistributedPipeline pipeline)
           
PCollectionImpl(String name, DistributedPipeline pipeline, ParallelDoOptions doOptions)
           
PTableBase(String name, DistributedPipeline pipeline)
           
PTableBase(String name, DistributedPipeline pipeline, ParallelDoOptions options)
           
 

Uses of DistributedPipeline in org.apache.crunch.impl.mr
 

Subclasses of DistributedPipeline in org.apache.crunch.impl.mr
 class MRPipeline
          Pipeline implementation that is executed within Hadoop MapReduce.
 

Uses of DistributedPipeline in org.apache.crunch.impl.spark
 

Subclasses of DistributedPipeline in org.apache.crunch.impl.spark
 class SparkPipeline
           
 

Uses of DistributedPipeline in org.apache.crunch.impl.spark.collect
 

Methods in org.apache.crunch.impl.spark.collect with parameters of type DistributedPipeline
<S> BaseInputCollection<S>
SparkCollectFactory.createInputCollection(Source<S> source, DistributedPipeline pipeline)
           
<K,V> BaseInputTable<K,V>
SparkCollectFactory.createInputTable(TableSource<K,V> source, DistributedPipeline pipeline)
           
 

Constructors in org.apache.crunch.impl.spark.collect with parameters of type DistributedPipeline
EmptyPCollection(DistributedPipeline pipeline, PType<T> ptype)
           
EmptyPTable(DistributedPipeline pipeline, PTableType<K,V> ptype)
           
InputTable(TableSource<K,V> source, DistributedPipeline pipeline)
           
 



Copyright © 2014 The Apache Software Foundation. All Rights Reserved.