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 © 2017 The Apache Software Foundation. All rights reserved.