com.cloudera.crunch.impl.mr.run
Class CrunchInputs

java.lang.Object
  com.cloudera.crunch.impl.mr.run.CrunchInputs

public class CrunchInputs
extends Object

Constructor Summary

CrunchInputs()

Method Summary

static void	addInputPath(org.apache.hadoop.mapreduce.Job job, org.apache.hadoop.fs.Path path, Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass, int nodeIndex)
static Map<Class<? extends org.apache.hadoop.mapreduce.InputFormat>,Map<Integer,List<org.apache.hadoop.fs.Path>>>	getFormatNodeMap(org.apache.hadoop.mapreduce.JobContext job)

Methods inherited from class java.lang.Object

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

Constructor Detail

CrunchInputs

public CrunchInputs()

Method Detail

addInputPath

public static void addInputPath(org.apache.hadoop.mapreduce.Job job,
                                org.apache.hadoop.fs.Path path,
                                Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass,
                                int nodeIndex)

getFormatNodeMap

public static Map<Class<? extends org.apache.hadoop.mapreduce.InputFormat>,Map<Integer,List<org.apache.hadoop.fs.Path>>> getFormatNodeMap(org.apache.hadoop.mapreduce.JobContext job)