org.apache.hadoop.mapred.lib
Class MultipleInputs

java.lang.Object
  extended by org.apache.hadoop.mapred.lib.MultipleInputs

@InterfaceAudience.Public
@InterfaceStability.Stable
public class MultipleInputs
extends Object

This class supports MapReduce jobs that have multiple input paths with a different InputFormat and Mapper for each path


Constructor Summary
MultipleInputs()
           
 
Method Summary
static void addInputPath(JobConf conf, Path path, Class<? extends InputFormat> inputFormatClass)
          Add a Path with a custom InputFormat to the list of inputs for the map-reduce job.
static void addInputPath(JobConf conf, Path path, Class<? extends InputFormat> inputFormatClass, Class<? extends Mapper> mapperClass)
          Add a Path with a custom InputFormat and Mapper to the list of inputs for the map-reduce job.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MultipleInputs

public MultipleInputs()
Method Detail

addInputPath

public static void addInputPath(JobConf conf,
                                Path path,
                                Class<? extends InputFormat> inputFormatClass)
Add a Path with a custom InputFormat to the list of inputs for the map-reduce job.

Parameters:
conf - The configuration of the job
path - Path to be added to the list of inputs for the job
inputFormatClass - InputFormat class to use for this path

addInputPath

public static void addInputPath(JobConf conf,
                                Path path,
                                Class<? extends InputFormat> inputFormatClass,
                                Class<? extends Mapper> mapperClass)
Add a Path with a custom InputFormat and Mapper to the list of inputs for the map-reduce job.

Parameters:
conf - The configuration of the job
path - Path to be added to the list of inputs for the job
inputFormatClass - InputFormat class to use for this path
mapperClass - Mapper class to use for this path


Copyright © 2012 Apache Software Foundation. All Rights Reserved.