Uses of Class
org.apache.crunch.CreateOptions

Packages that use CreateOptions

Package	Description
org.apache.crunch	Client-facing API and core abstractions.
org.apache.crunch.impl.dist
org.apache.crunch.impl.mem	In-memory Pipeline implementation for rapid prototyping and testing.
org.apache.crunch.impl.spark
org.apache.crunch.impl.spark.collect

Uses of CreateOptions in org.apache.crunch

Methods in org.apache.crunch that return CreateOptions

Modifier and Type	Method and Description
static CreateOptions	CreateOptions.name(String name)
static CreateOptions	CreateOptions.nameAndParallelism(String name, int parallelism)
static CreateOptions	CreateOptions.none()
static CreateOptions	CreateOptions.parallelism(int parallelism)

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

Modifier and Type	Method and Description
<K,V> PTable<K,V>	Pipeline.create(Iterable<Pair<K,V>> contents, PTableType<K,V> ptype, CreateOptions options) Creates a PTable containing the values found in the given Iterable using an implementation-specific distribution mechanism.
<T> PCollection<T>	Pipeline.create(Iterable<T> contents, PType<T> ptype, CreateOptions options) Creates a PCollection containing the values found in the given Iterable using an implementation-specific distribution mechanism.

Uses of CreateOptions in org.apache.crunch.impl.dist

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

Modifier and Type	Method and Description
<K,V> PTable<K,V>	DistributedPipeline.create(Iterable<Pair<K,V>> contents, PTableType<K,V> ptype, CreateOptions options)
<S> PCollection<S>	DistributedPipeline.create(Iterable<S> contents, PType<S> ptype, CreateOptions options)

Uses of CreateOptions in org.apache.crunch.impl.mem

Methods in org.apache.crunch.impl.mem with parameters of type CreateOptions

Modifier and Type	Method and Description
<K,V> PTable<K,V>	MemPipeline.create(Iterable<Pair<K,V>> contents, PTableType<K,V> ptype, CreateOptions options)
<T> PCollection<T>	MemPipeline.create(Iterable<T> iterable, PType<T> ptype, CreateOptions options)

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

Methods in org.apache.crunch.impl.spark with parameters of type CreateOptions

Modifier and Type	Method and Description
<K,V> PTable<K,V>	SparkPipeline.create(Iterable<Pair<K,V>> contents, PTableType<K,V> ptype, CreateOptions options)
<S> PCollection<S>	SparkPipeline.create(Iterable<S> contents, PType<S> ptype, CreateOptions options)

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

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

Constructor and Description
CreatedCollection(SparkPipeline p, Iterable<T> contents, PType<T> ptype, CreateOptions options)
CreatedTable(SparkPipeline pipeline, Iterable<Pair<K,V>> contents, PTableType<K,V> ptype, CreateOptions options)