org.apache.trevni.avro.mapreduce

Class AvroTrevniKeyInputFormat<T>

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<K,V>

org.apache.hadoop.mapreduce.lib.input.FileInputFormat<AvroKey<T>,NullWritable>

org.apache.trevni.avro.mapreduce.AvroTrevniKeyInputFormat<T>

public class AvroTrevniKeyInputFormat<T>
extends FileInputFormat<AvroKey<T>,NullWritable>

An InputFormat for Trevni files. This implement was modeled off AvroKeyInputFormat to allow for easy transition A MapReduce InputFormat that can handle Trevni container files.

Keys are AvroKey wrapper objects that contain the Trevni data. Since Trevni container files store only records (not key/value pairs), the value from this InputFormat is a NullWritable.

A subset schema to be read may be specified with AvroJob.setInputKeySchema(org.apache.hadoop.mapreduce.Job, org.apache.avro.Schema).

Nested Class Summary

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

FileInputFormat.Counter

Constructor Summary

Constructors

Constructor and Description
AvroTrevniKeyInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
RecordReader<AvroKey<T>,NullWritable>	createRecordReader(InputSplit split, TaskAttemptContext context)

Methods inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat

addInputPath, addInputPaths, computeSplitSize, getBlockIndex, getFormatMinSplitSize, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, getSplits, isSplitable, listStatus, 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

AvroTrevniKeyInputFormat

public AvroTrevniKeyInputFormat()

Method Detail

createRecordReader

public RecordReader<AvroKey<T>,NullWritable> createRecordReader(InputSplit split,
                                                       TaskAttemptContext context)
                                                         throws IOException,
                                                                InterruptedException

Specified by:

createRecordReader in class InputFormat<AvroKey<T>,NullWritable>

Throws:

IOException

InterruptedException