public class SequenceFileAsTextInputFormat extends SequenceFileInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
Constructor and Description |
---|
SequenceFileAsTextInputFormat() |
Modifier and Type | Method and Description |
---|---|
RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> |
createRecordReader(InputSplit split,
TaskAttemptContext context)
Create a record reader for a given split.
|
getFormatMinSplitSize, listStatus
addInputPath, addInputPaths, computeSplitSize, getBlockIndex, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, getSplits, isSplitable, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSize
public RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> createRecordReader(InputSplit split, TaskAttemptContext context) throws java.io.IOException
InputFormat
RecordReader.initialize(InputSplit, TaskAttemptContext)
before
the split is used.createRecordReader
in class SequenceFileInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
split
- the split to be readcontext
- the information about the taskjava.io.IOException
Copyright © 2009 The Apache Software Foundation