Class AvroTrevniKeyValueRecordReader<K,V>

java.lang.Object
org.apache.hadoop.mapreduce.RecordReader<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>>
org.apache.trevni.avro.mapreduce.AvroTrevniRecordReaderBase<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>,org.apache.avro.generic.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<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>,org.apache.avro.generic.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.