public class InputSplitInputFormat extends BaseWrapperInputFormat<org.apache.hadoop.io.NullWritable,org.apache.hadoop.mapreduce.InputSplit>
Modifier and Type | Class and Description |
---|---|
static class |
InputSplitInputFormat.InputSplitRecordReader<V extends org.apache.hadoop.mapreduce.InputSplit> |
iInputFormat
Constructor and Description |
---|
InputSplitInputFormat() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.mapreduce.InputSplit> |
createRecordReader(org.apache.hadoop.mapreduce.InputSplit arg0, org.apache.hadoop.mapreduce.TaskAttemptContext arg1) |
createInternalInputFormat, createRecordInfoProvider, getInternalInputFormat, getInternalInputFormatClass, getRecordInfoProvider, getRecordInfoProviderClass, getSplits, setInternalInputFormatClass, setRecordInfoProviderClass
public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.mapreduce.InputSplit> createRecordReader(org.apache.hadoop.mapreduce.InputSplit arg0, org.apache.hadoop.mapreduce.TaskAttemptContext arg1) throws java.io.IOException, java.lang.InterruptedException
createRecordReader
in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,org.apache.hadoop.mapreduce.InputSplit>
java.io.IOException
java.lang.InterruptedException
Copyright © 2016 Oracle and/or its affiliates. All Rights Reserved.