K - The type of the Avro key to read.V - The type of the Avro value to read.public class CombineAvroKeyValueFileInputFormat<K,V> extends CombineFileInputFormat<AvroKey<K>,AvroValue<V>>
FileInputFormat.CounterSPLIT_MINSIZE_PERNODE, SPLIT_MINSIZE_PERRACKDEFAULT_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 |
|---|
CombineAvroKeyValueFileInputFormat() |
| Modifier and Type | Method and Description |
|---|---|
RecordReader<AvroKey<K>,AvroValue<V>> |
createRecordReader(InputSplit inputSplit,
TaskAttemptContext taskAttemptContext) |
createPool, createPool, getFileBlockLocations, getSplits, isSplitable, setMaxSplitSize, setMinSplitSizeNode, setMinSplitSizeRackaddInputPath, addInputPathRecursively, addInputPaths, computeSplitSize, getBlockIndex, getFormatMinSplitSize, getInputDirRecursive, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, listStatus, makeSplit, makeSplit, setInputDirRecursive, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSizepublic RecordReader<AvroKey<K>,AvroValue<V>> createRecordReader(InputSplit inputSplit, TaskAttemptContext taskAttemptContext) throws IOException
createRecordReader in class CombineFileInputFormat<AvroKey<K>,AvroValue<V>>IOExceptionCopyright © 2009–2020 The Apache Software Foundation. All rights reserved.