@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_NONRECURSIVE_IGNORE_SUBDIRS, 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> |
getRecordReader(InputSplit split,
JobConf conf,
Reporter reporter)
This is not implemented yet.
|
createPool, createPool, createRecordReader, getSplits, isSplitable, listStatus
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> getRecordReader(InputSplit split, JobConf conf, Reporter reporter) throws IOException
CombineFileInputFormat
getRecordReader
in interface InputFormat<K,V>
getRecordReader
in class CombineFileInputFormat<K,V>
split
- the InputSplit
conf
- the job that this split belongs toRecordReader
IOException
Copyright © 2021 Apache Software Foundation. All rights reserved.