public class MultiInputFormat extends 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 IOException
IOException
public InputSplit[] getSplits(JobConf job, int numSplits) throws IOException
getSplits
in interface InputFormat
job
- of type JobConfnumSplits
- of type intIOException
- whenpublic RecordReader getRecordReader(InputSplit split, JobConf job, Reporter reporter) throws IOException
getRecordReader
in interface InputFormat
split
- of type InputSplitjob
- of type JobConfreporter
- of type ReporterIOException
- whenCopyright © 2007-2015 Concurrent, Inc. All Rights Reserved.