public static class MultiFileWordCount.MyInputFormat extends CombineFileInputFormat<MultiFileWordCount.WordOffset,org.apache.hadoop.io.Text>
CombineFileInputFormat
, one should extend it, to return a
(custom) RecordReader
. CombineFileInputFormat uses
CombineFileSplit
s.Constructor and Description |
---|
MultiFileWordCount.MyInputFormat() |
Modifier and Type | Method and Description |
---|---|
RecordReader<MultiFileWordCount.WordOffset,org.apache.hadoop.io.Text> |
createRecordReader(InputSplit split,
TaskAttemptContext context)
This is not implemented yet.
|
createPool, createPool, getFileBlockLocations, getSplits, isSplitable, setMaxSplitSize, setMinSplitSizeNode, setMinSplitSizeRack
addInputPath, addInputPaths, computeSplitSize, getBlockIndex, getFormatMinSplitSize, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, listStatus, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSize
public RecordReader<MultiFileWordCount.WordOffset,org.apache.hadoop.io.Text> createRecordReader(InputSplit split, TaskAttemptContext context) throws java.io.IOException
CombineFileInputFormat
createRecordReader
in class CombineFileInputFormat<MultiFileWordCount.WordOffset,org.apache.hadoop.io.Text>
split
- the split to be readcontext
- the information about the taskjava.io.IOException
Copyright © 2009 The Apache Software Foundation