Package org.apache.avro.mapreduce
Class AvroSequenceFileInputFormat<K,V>
java.lang.Object
org.apache.hadoop.mapreduce.InputFormat<K,V>
org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K,V>
org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat<K,V>
org.apache.avro.mapreduce.AvroSequenceFileInputFormat<K,V>
- Type Parameters:
K
- The input key type.V
- The input value type.
An input format for reading from AvroSequenceFiles (sequence files that
support Avro data).
-
Nested Class Summary
Modifier and TypeClassDescriptionprotected class
Reads records from a SequenceFile that supports Avro data.Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
FileInputFormat.Counter
-
Field Summary
Fields inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
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 Summary
-
Method Summary
Modifier and TypeMethodDescriptioncreateRecordReader
(InputSplit inputSplit, TaskAttemptContext context) Methods inherited from class org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat
getFormatMinSplitSize, listStatus
Methods inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
addInputPath, addInputPathRecursively, addInputPaths, computeSplitSize, getBlockIndex, getInputDirRecursive, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, getSplits, isSplitable, makeSplit, makeSplit, setInputDirRecursive, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSize
-
Constructor Details
-
AvroSequenceFileInputFormat
public AvroSequenceFileInputFormat()
-
-
Method Details
-
createRecordReader
public RecordReader<K,V> createRecordReader(InputSplit inputSplit, TaskAttemptContext context) throws IOException - Overrides:
createRecordReader
in classSequenceFileInputFormat<K,
V> - Throws:
IOException
-