org.apache.hadoop.mapreduce.lib.input

Class MultipleInputs

java.lang.Object

org.apache.hadoop.mapreduce.lib.input.MultipleInputs

public class MultipleInputs
extends java.lang.Object

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

Constructor Summary

Constructors

Constructor and Description
MultipleInputs()

Method Summary

Methods

Modifier and Type	Method and Description
static void	addInputPath(Job job, org.apache.hadoop.fs.Path path, java.lang.Class<? extends InputFormat> inputFormatClass) Add a Path with a custom InputFormat to the list of inputs for the map-reduce job.
static void	addInputPath(Job job, org.apache.hadoop.fs.Path path, java.lang.Class<? extends InputFormat> inputFormatClass, java.lang.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(Job job,
                org.apache.hadoop.fs.Path path,
                java.lang.Class<? extends InputFormat> inputFormatClass)

Add a Path with a custom InputFormat to the list of inputs for the map-reduce job.

Parameters:

job - 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(Job job,
                org.apache.hadoop.fs.Path path,
                java.lang.Class<? extends InputFormat> inputFormatClass,
                java.lang.Class<? extends Mapper> mapperClass)

Add a Path with a custom InputFormat and Mapper to the list of inputs for the map-reduce job.

Parameters:

job - 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