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