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<AvroKey<K>,AvroValue<V>,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 |
---|---|
AvroKey<K> |
getCurrentKey() |
AvroValue<V> |
getCurrentValue() |
boolean |
nextKeyValue() |
close, getCurrentRecord, getProgress, initialize
public AvroKey<K> getCurrentKey() throws IOException, InterruptedException
getCurrentKey
in class RecordReader<AvroKey<K>,AvroValue<V>>
IOException
InterruptedException
public AvroValue<V> getCurrentValue() throws IOException, InterruptedException
getCurrentValue
in class RecordReader<AvroKey<K>,AvroValue<V>>
IOException
InterruptedException
public boolean nextKeyValue() throws IOException, InterruptedException
nextKeyValue
in class AvroTrevniRecordReaderBase<AvroKey<K>,AvroValue<V>,GenericRecord>
IOException
InterruptedException
Copyright © 2009–2017 The Apache Software Foundation. All rights reserved.