K
- The type of the Avro key to read.V
- The type of the Avro value to read.public class AvroKeyValueRecordReader<K,V> extends AvroRecordReaderBase<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 |
---|
AvroKeyValueRecordReader(Schema keyReaderSchema,
Schema valueReaderSchema)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
AvroKey<K> |
getCurrentKey() |
AvroValue<V> |
getCurrentValue() |
boolean |
nextKeyValue() |
close, createAvroFileReader, createSeekableInput, getCurrentRecord, getProgress, initialize
public boolean nextKeyValue() throws IOException, InterruptedException
nextKeyValue
in class AvroRecordReaderBase<AvroKey<K>,AvroValue<V>,GenericRecord>
IOException
InterruptedException
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
Copyright © 2009–2017 The Apache Software Foundation. All rights reserved.