public class MultiInputFormat extends java.lang.Object implements InputFormat
Constructor and Description |
---|
MultiInputFormat() |
Modifier and Type | Method and Description |
---|---|
static void |
addInputFormat(JobConf toJob,
JobConf... fromJobs)
Used to set the current JobConf with all sub jobs configurations.
|
RecordReader |
getRecordReader(InputSplit split,
JobConf job,
Reporter reporter)
Method getRecordReader delegates to the appropriate InputFormat.
|
InputSplit[] |
getSplits(JobConf job,
int numSplits)
Method getSplits delegates to the appropriate InputFormat.
|
void |
validateInput(JobConf job) |
public MultiInputFormat()
public static void addInputFormat(JobConf toJob, JobConf... fromJobs)
toJob
- fromJobs
- public void validateInput(JobConf job) throws java.io.IOException
java.io.IOException
public InputSplit[] getSplits(JobConf job, int numSplits) throws java.io.IOException
getSplits
in interface InputFormat
job
- of type JobConfnumSplits
- of type intjava.io.IOException
- whenpublic RecordReader getRecordReader(InputSplit split, JobConf job, Reporter reporter) throws java.io.IOException
getRecordReader
in interface InputFormat
split
- of type InputSplitjob
- of type JobConfreporter
- of type Reporterjava.io.IOException
- whenCopyright © 2007-2015 Xplenty, Inc. All Rights Reserved.