public class DynamicInputFormat<K,V> extends InputFormat<K,V>
Constructor and Description |
---|
DynamicInputFormat() |
Modifier and Type | Method and Description |
---|---|
RecordReader<K,V> |
createRecordReader(InputSplit inputSplit,
TaskAttemptContext taskAttemptContext)
Implementation of Inputformat::createRecordReader().
|
List<InputSplit> |
getSplits(JobContext jobContext)
Implementation of InputFormat::getSplits().
|
public List<InputSplit> getSplits(JobContext jobContext) throws IOException, InterruptedException
getSplits
in class InputFormat<K,V>
jobContext
- JobContext for the map job.IOException,
- on failure.InterruptedException
IOException
public RecordReader<K,V> createRecordReader(InputSplit inputSplit, TaskAttemptContext taskAttemptContext) throws IOException, InterruptedException
createRecordReader
in class InputFormat<K,V>
inputSplit
- The split for which the RecordReader is required.taskAttemptContext
- TaskAttemptContext for the current attempt.IOException,
- on failure.InterruptedException
IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.