org.apache.crunch.impl.mr.plan
Class JobPrototype

java.lang.Object
  extended by org.apache.crunch.impl.mr.plan.JobPrototype

public class JobPrototype
extends Object


Method Summary
 void addDependency(JobPrototype dependency)
           
 void addReducePaths(com.google.common.collect.HashMultimap<Target,org.apache.crunch.impl.mr.plan.NodePath> outputPaths)
           
static JobPrototype createMapOnlyJob(com.google.common.collect.HashMultimap<Target,org.apache.crunch.impl.mr.plan.NodePath> mapNodePaths, org.apache.hadoop.fs.Path workingPath)
           
static JobPrototype createMapReduceJob(PGroupedTableImpl<?,?> group, Set<org.apache.crunch.impl.mr.plan.NodePath> inputs, org.apache.hadoop.fs.Path workingPath)
           
 CrunchJob getCrunchJob(Class<?> jarClass, org.apache.hadoop.conf.Configuration conf, Pipeline pipeline)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

createMapReduceJob

public static JobPrototype createMapReduceJob(PGroupedTableImpl<?,?> group,
                                              Set<org.apache.crunch.impl.mr.plan.NodePath> inputs,
                                              org.apache.hadoop.fs.Path workingPath)

createMapOnlyJob

public static JobPrototype createMapOnlyJob(com.google.common.collect.HashMultimap<Target,org.apache.crunch.impl.mr.plan.NodePath> mapNodePaths,
                                            org.apache.hadoop.fs.Path workingPath)

addReducePaths

public void addReducePaths(com.google.common.collect.HashMultimap<Target,org.apache.crunch.impl.mr.plan.NodePath> outputPaths)

addDependency

public void addDependency(JobPrototype dependency)

getCrunchJob

public CrunchJob getCrunchJob(Class<?> jarClass,
                              org.apache.hadoop.conf.Configuration conf,
                              Pipeline pipeline)
                       throws IOException
Throws:
IOException


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