org.apache.hadoop.mapreduce.lib.input

类 MultipleInputs

java.lang.Object

org.apache.hadoop.mapreduce.lib.input.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

字段概要

字段

限定符和类型	字段和说明
static String	DIR_FORMATS
static String	DIR_MAPPERS

构造器概要

构造器

构造器和说明
MultipleInputs()

方法概要

方法

限定符和类型	方法和说明
static void	addInputPath(Job job, 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(Job job, 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.

从类继承的方法 java.lang.Object

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

字段详细资料

DIR_FORMATS

public static final String DIR_FORMATS

另请参阅:

常量字段值

DIR_MAPPERS

public static final String DIR_MAPPERS

另请参阅:

常量字段值

构造器详细资料

MultipleInputs

public MultipleInputs()

方法详细资料

addInputPath

public static void addInputPath(Job job,
                Path path,
                Class<? extends InputFormat> inputFormatClass)

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

参数:

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,
                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.

参数:

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