org.apache.crunch

Class ParallelDoOptions

java.lang.Object

org.apache.crunch.ParallelDoOptions

public class ParallelDoOptions
extends Object

Container class that includes optional information about a parallelDo operation applied to a PCollection. Primarily used within the Crunch framework itself for certain types of advanced processing operations, such as in-memory joins that require reading a file from the filesystem into a DoFn.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ParallelDoOptions.Builder

Method Summary

Modifier and Type	Method and Description
static ParallelDoOptions.Builder	builder()
void	configure(org.apache.hadoop.conf.Configuration conf) Applies the key-value pairs that were associated with this instance to the given Configuration object.
Set<SourceTarget<?>>	getSourceTargets() Deprecated.
Set<Target>	getTargets()

Methods inherited from class java.lang.Object

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

Method Detail

getSourceTargets

@Deprecated
public Set<SourceTarget<?>> getSourceTargets()

Deprecated.

getTargets

public Set<Target> getTargets()

configure

public void configure(org.apache.hadoop.conf.Configuration conf)

Applies the key-value pairs that were associated with this instance to the given Configuration object. This is called just before the configure method on the DoFn corresponding to this instance is called, so it is possible for the DoFn to see (and possibly override) these settings.

builder

public static ParallelDoOptions.Builder builder()