org.apache.trevni.avro.mapreduce

Class AvroTrevniKeyValueRecordReader<K,V>

java.lang.Object

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

org.apache.trevni.avro.mapreduce.AvroTrevniRecordReaderBase<AvroKey<K>,AvroValue<V>,GenericRecord>

org.apache.trevni.avro.mapreduce.AvroTrevniKeyValueRecordReader<K,V>

Type Parameters:

K - The type of the Avro key to read.

V - The type of the Avro value to read.

All Implemented Interfaces:

Closeable, AutoCloseable

public class AvroTrevniKeyValueRecordReader<K,V>
extends AvroTrevniRecordReaderBase<AvroKey<K>,AvroValue<V>,GenericRecord>

Reads Trevni generic records from an Trevni container file, where the records contain two fields: 'key' and 'value'.

The contents of the 'key' field will be parsed into an AvroKey object. The contents of the 'value' field will be parsed into an AvroValue object.

Constructor Summary

Constructors

Constructor and Description
AvroTrevniKeyValueRecordReader()

Method Summary

Methods

Modifier and Type	Method and Description
AvroKey<K>	getCurrentKey()
AvroValue<V>	getCurrentValue()
boolean	nextKeyValue()

Methods inherited from class org.apache.trevni.avro.mapreduce.AvroTrevniRecordReaderBase

close, getCurrentRecord, getProgress, initialize

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroTrevniKeyValueRecordReader

public AvroTrevniKeyValueRecordReader()

Method Detail

getCurrentKey

public AvroKey<K> getCurrentKey()
                         throws IOException,
                                InterruptedException

Specified by:

getCurrentKey in class RecordReader<AvroKey<K>,AvroValue<V>>

Throws:

IOException

InterruptedException

getCurrentValue

public AvroValue<V> getCurrentValue()
                             throws IOException,
                                    InterruptedException

Specified by:

getCurrentValue in class RecordReader<AvroKey<K>,AvroValue<V>>

Throws:

IOException

InterruptedException

nextKeyValue

public boolean nextKeyValue()
                     throws IOException,
                            InterruptedException

Overrides:

nextKeyValue in class AvroTrevniRecordReaderBase<AvroKey<K>,AvroValue<V>,GenericRecord>

Throws:

IOException

InterruptedException