org.apache.avro.mapred

Class AvroRecordReader<T>

java.lang.Object

org.apache.avro.mapred.AvroRecordReader<T>

All Implemented Interfaces:

org.apache.hadoop.mapred.RecordReader<AvroWrapper<T>,org.apache.hadoop.io.NullWritable>

Direct Known Subclasses:

SequenceFileRecordReader

public class AvroRecordReader<T>
extends Object
implements org.apache.hadoop.mapred.RecordReader<AvroWrapper<T>,org.apache.hadoop.io.NullWritable>

An RecordReader for Avro data files.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AvroRecordReader(FileReader<T> reader, org.apache.hadoop.mapred.FileSplit split)
	AvroRecordReader(org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.FileSplit split)

Method Summary

Modifier and Type	Method and Description
void	close()
AvroWrapper<T>	createKey()
org.apache.hadoop.io.NullWritable	createValue()
long	getPos()
float	getProgress()
boolean	next(AvroWrapper<T> wrapper, org.apache.hadoop.io.NullWritable ignore)

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroRecordReader

public AvroRecordReader(org.apache.hadoop.mapred.JobConf job,
                        org.apache.hadoop.mapred.FileSplit split)
                 throws IOException

Throws:

IOException

AvroRecordReader

protected AvroRecordReader(FileReader<T> reader,
                           org.apache.hadoop.mapred.FileSplit split)
                    throws IOException

Throws:

IOException

Method Detail

createKey

public AvroWrapper<T> createKey()

Specified by:

createKey in interface org.apache.hadoop.mapred.RecordReader<AvroWrapper<T>,org.apache.hadoop.io.NullWritable>

createValue

public org.apache.hadoop.io.NullWritable createValue()

Specified by:

createValue in interface org.apache.hadoop.mapred.RecordReader<AvroWrapper<T>,org.apache.hadoop.io.NullWritable>

next

public boolean next(AvroWrapper<T> wrapper,
                    org.apache.hadoop.io.NullWritable ignore)
             throws IOException

Specified by:

next in interface org.apache.hadoop.mapred.RecordReader<AvroWrapper<T>,org.apache.hadoop.io.NullWritable>

Throws:

IOException

getProgress

public float getProgress()
                  throws IOException

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader<AvroWrapper<T>,org.apache.hadoop.io.NullWritable>

Throws:

IOException

getPos

public long getPos()
            throws IOException

Specified by:

getPos in interface org.apache.hadoop.mapred.RecordReader<AvroWrapper<T>,org.apache.hadoop.io.NullWritable>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader<AvroWrapper<T>,org.apache.hadoop.io.NullWritable>

Throws:

IOException