K
- The type of the Avro key to read.V
- The type of the Avro value to read.public class AvroTrevniKeyValueRecordReader<K,V> extends AvroTrevniRecordReaderBase<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>,org.apache.avro.generic.GenericRecord>
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 and Description |
---|
AvroTrevniKeyValueRecordReader() |
Modifier and Type | Method and Description |
---|---|
org.apache.avro.mapred.AvroKey<K> |
getCurrentKey() |
org.apache.avro.mapred.AvroValue<V> |
getCurrentValue() |
boolean |
nextKeyValue() |
close, getCurrentRecord, getProgress, initialize
public org.apache.avro.mapred.AvroKey<K> getCurrentKey() throws IOException, InterruptedException
getCurrentKey
in class RecordReader<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>>
IOException
InterruptedException
public org.apache.avro.mapred.AvroValue<V> getCurrentValue() throws IOException, InterruptedException
getCurrentValue
in class RecordReader<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>>
IOException
InterruptedException
public boolean nextKeyValue() throws IOException, InterruptedException
nextKeyValue
in class AvroTrevniRecordReaderBase<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>,org.apache.avro.generic.GenericRecord>
IOException
InterruptedException
Copyright © 2009–2023 The Apache Software Foundation. All rights reserved.