@InterfaceAudience.Public @InterfaceStability.Stable public class CombineSequenceFileInputFormat<K,V> extends CombineFileInputFormat<K,V>
CombineFileInputFormat
-equivalent for
SequenceFileInputFormat
.CombineFileInputFormat
SPLIT_MINSIZE_PERNODE, SPLIT_MINSIZE_PERRACK
DEFAULT_LIST_STATUS_NUM_THREADS, INPUT_DIR, INPUT_DIR_RECURSIVE, LIST_STATUS_NUM_THREADS, NUM_INPUT_FILES, PATHFILTER_CLASS, SPLIT_MAXSIZE, SPLIT_MINSIZE
Constructor and Description |
---|
CombineSequenceFileInputFormat() |
Modifier and Type | Method and Description |
---|---|
RecordReader<K,V> |
createRecordReader(InputSplit split,
TaskAttemptContext context)
This is not implemented yet.
|
createPool, createPool, getFileBlockLocations, getSplits, isSplitable, setMaxSplitSize, setMinSplitSizeNode, setMinSplitSizeRack
addInputPath, addInputPathRecursively, addInputPaths, computeSplitSize, getBlockIndex, getFormatMinSplitSize, getInputDirRecursive, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, listStatus, makeSplit, makeSplit, setInputDirRecursive, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSize
public RecordReader<K,V> createRecordReader(InputSplit split, TaskAttemptContext context) throws IOException
CombineFileInputFormat
createRecordReader
in class CombineFileInputFormat<K,V>
split
- the split to be readcontext
- the information about the taskIOException
Copyright © 2019 Apache Software Foundation. All rights reserved.