public class CreateOptions extends Object
Pipeline.create(java.lang.Iterable<T>, org.apache.crunch.types.PType<T>)
.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) |
public static CreateOptions none()
public static CreateOptions parallelism(int parallelism)
public static CreateOptions name(String name)
public static CreateOptions nameAndParallelism(String name, int parallelism)
public String getName()
public int getParallelism()
Copyright © 2016 The Apache Software Foundation. All rights reserved.