public class AvroUtf8InputFormat
extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<org.apache.avro.mapred.AvroWrapper<org.apache.avro.util.Utf8>,org.apache.hadoop.io.NullWritable>
An InputFormat for text files. Each line is
a Utf8 key; values are null.
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
public void configure(org.apache.hadoop.conf.Configuration conf)
createRecordReader
public org.apache.hadoop.mapreduce.RecordReader<org.apache.avro.mapred.AvroWrapper<org.apache.avro.util.Utf8>,org.apache.hadoop.io.NullWritable> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
throws IOException,
InterruptedException
Specified by:
createRecordReader in class org.apache.hadoop.mapreduce.InputFormat<org.apache.avro.mapred.AvroWrapper<org.apache.avro.util.Utf8>,org.apache.hadoop.io.NullWritable>