This project has retired. For details please refer to its Attic page.
ParallelDoOptions (Apache Crunch 0.9.0 API)

org.apache.crunch
Class ParallelDoOptions

java.lang.Object
  extended by 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()


Copyright © 2014 The Apache Software Foundation. All Rights Reserved.