org.apache.crunch

Class CreateOptions

java.lang.Object

org.apache.crunch.CreateOptions

public class CreateOptions
extends Object

Additional options that can be specified when creating a new PCollection using Pipeline.create(java.lang.Iterable<T>, org.apache.crunch.types.PType<T>).

Method Summary

Methods

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

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

none

public static CreateOptions none()

parallelism

public static CreateOptions parallelism(int parallelism)

name

public static CreateOptions name(String name)

nameAndParallelism

public static CreateOptions nameAndParallelism(String name,
                               int parallelism)

getName

public String getName()

getParallelism

public int getParallelism()