This project has retired. For details please refer to its Attic page.

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

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)
<S> BaseInputCollection<S>	PCollectionFactory.createInputCollection(Source<S> source, DistributedPipeline distributedPipeline, ParallelDoOptions doOpts)
<K,V> BaseInputTable<K,V>	PCollectionFactory.createInputTable(TableSource<K,V> source, 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

BaseInputCollection(Source<S> source, DistributedPipeline pipeline, ParallelDoOptions doOpts)

BaseInputTable(TableSource<K,V> source, 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

<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, DistributedPipeline pipeline, ParallelDoOptions doOpts)
<K,V> BaseInputTable<K,V>	SparkCollectFactory.createInputTable(TableSource<K,V> source, DistributedPipeline pipeline, ParallelDoOptions doOpts)

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

InputTable(TableSource<K,V> source, DistributedPipeline pipeline, ParallelDoOptions doOpts)