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

Uses of Class
org.apache.crunch.ParallelDoOptions

Packages that use ParallelDoOptions
org.apache.crunch Client-facing API and core abstractions. 
org.apache.crunch.impl.dist.collect   
org.apache.crunch.impl.mem.collect   
org.apache.crunch.impl.mr.collect   
org.apache.crunch.impl.mr.plan   
org.apache.crunch.impl.spark.collect   
 

Uses of ParallelDoOptions in org.apache.crunch
 

Methods in org.apache.crunch that return ParallelDoOptions
 ParallelDoOptions ParallelDoOptions.Builder.build()
           
 

Methods in org.apache.crunch with parameters of type ParallelDoOptions
<K,V> PTable<K,V>
PCollection.parallelDo(String name, DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type, ParallelDoOptions options)
          Similar to the other parallelDo instance, but returns a PTable instance instead of a PCollection.
<T> PCollection<T>
PCollection.parallelDo(String name, DoFn<S,T> doFn, PType<T> type, ParallelDoOptions options)
          Applies the given doFn to the elements of this PCollection and returns a new PCollection that is the output of this processing.
 

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

Fields in org.apache.crunch.impl.dist.collect declared as ParallelDoOptions
protected  ParallelDoOptions PCollectionImpl.doOptions
           
 

Methods in org.apache.crunch.impl.dist.collect that return ParallelDoOptions
 ParallelDoOptions PCollectionImpl.getParallelDoOptions()
           
 

Methods in org.apache.crunch.impl.dist.collect with parameters of type ParallelDoOptions
<S,T> BaseDoCollection<T>
PCollectionFactory.createDoCollection(String name, PCollectionImpl<S> chainingCollection, DoFn<S,T> fn, PType<T> type, ParallelDoOptions options)
           
<S,K,V> BaseDoTable<K,V>
PCollectionFactory.createDoTable(String name, PCollectionImpl<S> chainingCollection, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type, ParallelDoOptions options)
           
<K,V> PTable<K,V>
PCollectionImpl.parallelDo(String name, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type, ParallelDoOptions options)
           
<T> PCollection<T>
PCollectionImpl.parallelDo(String name, DoFn<S,T> fn, PType<T> type, ParallelDoOptions options)
           
 

Constructors in org.apache.crunch.impl.dist.collect with parameters of type ParallelDoOptions
BaseDoCollection(String name, PCollectionImpl<T> parent, DoFn<T,S> fn, PType<S> ptype, ParallelDoOptions options)
           
BaseDoTable(String name, PCollectionImpl<S> parent, CombineFn<K,V> combineFn, DoFn<S,Pair<K,V>> fn, PTableType<K,V> ntype, ParallelDoOptions options)
           
BaseDoTable(String name, PCollectionImpl<S> parent, DoFn<S,Pair<K,V>> fn, PTableType<K,V> ntype, ParallelDoOptions options)
           
PCollectionImpl(String name, DistributedPipeline pipeline, ParallelDoOptions doOptions)
           
PTableBase(String name, DistributedPipeline pipeline, ParallelDoOptions options)
           
 

Uses of ParallelDoOptions in org.apache.crunch.impl.mem.collect
 

Methods in org.apache.crunch.impl.mem.collect with parameters of type ParallelDoOptions
<K,V> PTable<K,V>
MemCollection.parallelDo(String name, DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type, ParallelDoOptions options)
           
<T> PCollection<T>
MemCollection.parallelDo(String name, DoFn<S,T> doFn, PType<T> type, ParallelDoOptions options)
           
 

Uses of ParallelDoOptions in org.apache.crunch.impl.mr.collect
 

Methods in org.apache.crunch.impl.mr.collect with parameters of type ParallelDoOptions
<S,T> BaseDoCollection<T>
MRCollectionFactory.createDoCollection(String name, PCollectionImpl<S> parent, DoFn<S,T> fn, PType<T> type, ParallelDoOptions options)
           
<S,K,V> BaseDoTable<K,V>
MRCollectionFactory.createDoTable(String name, PCollectionImpl<S> parent, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type, ParallelDoOptions options)
           
 

Uses of ParallelDoOptions in org.apache.crunch.impl.mr.plan
 

Methods in org.apache.crunch.impl.mr.plan with parameters of type ParallelDoOptions
static DoNode DoNode.createFnNode(String name, DoFn<?,?> function, PType<?> ptype, ParallelDoOptions options)
           
 

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

Methods in org.apache.crunch.impl.spark.collect with parameters of type ParallelDoOptions
<S,T> BaseDoCollection<T>
SparkCollectFactory.createDoCollection(String name, PCollectionImpl<S> parent, DoFn<S,T> fn, PType<T> type, ParallelDoOptions options)
           
<S,K,V> BaseDoTable<K,V>
SparkCollectFactory.createDoTable(String name, PCollectionImpl<S> parent, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type, ParallelDoOptions options)
           
 



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