public static class IntegrationTestBulkLoad.ITBulkLoadInputFormat
extends <any>
| Constructor and Description |
|---|
ITBulkLoadInputFormat() |
| Modifier and Type | Method and Description |
|---|---|
<any> |
createRecordReader(InputSplit split,
TaskAttemptContext context) |
java.util.List<InputSplit> |
getSplits(JobContext context) |
public java.util.List<InputSplit> getSplits(JobContext context)
throws java.io.IOException,
java.lang.InterruptedException
java.io.IOExceptionjava.lang.InterruptedExceptionpublic <any> createRecordReader(InputSplit split,
TaskAttemptContext context)
throws java.io.IOException,
java.lang.InterruptedException
java.io.IOExceptionjava.lang.InterruptedException