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.

public class AvroSequenceFileInputFormat<K,V>
extends org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat<K,V>

An input format for reading from AvroSequenceFiles (sequence files that support Avro data).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AvroSequenceFileInputFormat.AvroSequenceFileRecordReader Reads records from a SequenceFile that supports Avro data.

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat

org.apache.hadoop.mapreduce.lib.input.FileInputFormat.Counter

Constructor Summary

Constructors

Constructor and Description
AvroSequenceFileInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.RecordReader<K,V>	createRecordReader(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.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, addInputPaths, computeSplitSize, getBlockIndex, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, getSplits, isSplitable, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSize

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AvroSequenceFileInputFormat

public AvroSequenceFileInputFormat()

Method Detail

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<K,V> createRecordReader(org.apache.hadoop.mapreduce.InputSplit inputSplit,
                                                               org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                 throws IOException

Overrides:

createRecordReader in class org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat<K,V>

Throws:

IOException