Uses of Class
org.apache.crunch.ParallelDoOptions

Packages that use ParallelDoOptions

Package	Description
org.apache.crunch	Client-facing API and core abstractions.
org.apache.crunch.impl.dist.collect
org.apache.crunch.impl.spark.collect

Uses of ParallelDoOptions in org.apache.crunch

Methods in org.apache.crunch that return ParallelDoOptions

Modifier and Type	Method and Description
ParallelDoOptions	ParallelDoOptions.Builder.build()

Methods in org.apache.crunch with parameters of type ParallelDoOptions

Modifier and Type	Method and Description
<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

Methods in org.apache.crunch.impl.dist.collect that return ParallelDoOptions

Modifier and Type	Method and Description
ParallelDoOptions	PCollectionImpl.getParallelDoOptions()

Methods in org.apache.crunch.impl.dist.collect with parameters of type ParallelDoOptions

Modifier and Type	Method and Description
<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)
<S> BaseInputCollection<S>	PCollectionFactory.createInputCollection(Source<S> source, String named, DistributedPipeline distributedPipeline, ParallelDoOptions doOpts)
<K,V> BaseInputTable<K,V>	PCollectionFactory.createInputTable(TableSource<K,V> source, String named, DistributedPipeline distributedPipeline, ParallelDoOptions doOpts)
<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

Constructor and Description
BaseInputCollection(Source<S> source, String name, DistributedPipeline pipeline, ParallelDoOptions doOpts)
BaseInputTable(TableSource<K,V> source, String name, DistributedPipeline pipeline, ParallelDoOptions doOpts)
PCollectionImpl(String name, DistributedPipeline pipeline, ParallelDoOptions doOptions)
PTableBase(String name, DistributedPipeline pipeline, 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

Modifier and Type	Method and Description
<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)
<S> BaseInputCollection<S>	SparkCollectFactory.createInputCollection(Source<S> source, String named, DistributedPipeline pipeline, ParallelDoOptions doOpts)
<K,V> BaseInputTable<K,V>	SparkCollectFactory.createInputTable(TableSource<K,V> source, String named, DistributedPipeline pipeline, ParallelDoOptions doOpts)

Constructors in org.apache.crunch.impl.spark.collect with parameters of type ParallelDoOptions

Constructor and Description
InputTable(TableSource<K,V> source, String named, DistributedPipeline pipeline, ParallelDoOptions doOpts)