org.apache.crunch.impl.mr.run
Class CrunchInputs

java.lang.Object
  org.apache.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, InputBundle inputBundle, int nodeIndex)
static Map<InputBundle,Map<Integer,List<org.apache.hadoop.fs.Path>>>	getFormatNodeMap(org.apache.hadoop.mapreduce.JobContext job)

Methods inherited from class java.lang.Object

equals, 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,
                                InputBundle inputBundle,
                                int nodeIndex)

getFormatNodeMap

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