This project has retired. For details please refer to its Attic page.
CrunchInputs (Apache Crunch 0.3.0-incubating API)

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

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


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