io.druid.data.input.avro

Class AvroValueRecordReader

java.lang.Object

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

org.apache.avro.mapreduce.AvroRecordReaderBase<org.apache.hadoop.io.NullWritable,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>

io.druid.data.input.avro.AvroValueRecordReader

All Implemented Interfaces:

Closeable, AutoCloseable

public class AvroValueRecordReader
extends org.apache.avro.mapreduce.AvroRecordReaderBase<org.apache.hadoop.io.NullWritable,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord>

Constructor Summary

Constructors

Constructor and Description
AvroValueRecordReader(org.apache.avro.Schema readerSchema)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.io.NullWritable	getCurrentKey()
org.apache.avro.generic.GenericRecord	getCurrentValue()

Methods inherited from class org.apache.avro.mapreduce.AvroRecordReaderBase

close, createAvroFileReader, createSeekableInput, getCurrentRecord, getProgress, initialize, nextKeyValue

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroValueRecordReader

public AvroValueRecordReader(org.apache.avro.Schema readerSchema)

Method Detail

getCurrentKey

public org.apache.hadoop.io.NullWritable getCurrentKey()
                                                throws IOException,
                                                       InterruptedException

Specified by:

getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.avro.generic.GenericRecord>

Throws:

IOException

InterruptedException

getCurrentValue

public org.apache.avro.generic.GenericRecord getCurrentValue()
                                                      throws IOException,
                                                             InterruptedException

Specified by:

getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.avro.generic.GenericRecord>

Throws:

IOException

InterruptedException