This project has retired. For details please refer to its Attic page.

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

static class

ParallelDoOptions.Builder

Method Summary

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()

Methods inherited from class java.lang.Object

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

Method Detail

getSourceTargets

public Set<SourceTarget<?>> getSourceTargets()

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()