T
- The (java) type of data in Avro container file.public class AvroKeyRecordReader<T> extends AvroRecordReaderBase<AvroKey<T>,NullWritable,T>
Constructor and Description |
---|
AvroKeyRecordReader(Schema readerSchema)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
AvroKey<T> |
getCurrentKey() |
NullWritable |
getCurrentValue() |
boolean |
nextKeyValue() |
close, createAvroFileReader, createSeekableInput, getCurrentRecord, getProgress, initialize
public AvroKeyRecordReader(Schema readerSchema)
readerSchema
- The reader schema to use for the records in the Avro container file.public boolean nextKeyValue() throws IOException, InterruptedException
nextKeyValue
in class AvroRecordReaderBase<AvroKey<T>,NullWritable,T>
IOException
InterruptedException
public AvroKey<T> getCurrentKey() throws IOException, InterruptedException
getCurrentKey
in class RecordReader<AvroKey<T>,NullWritable>
IOException
InterruptedException
public NullWritable getCurrentValue() throws IOException, InterruptedException
getCurrentValue
in class RecordReader<AvroKey<T>,NullWritable>
IOException
InterruptedException
Copyright © 2009–2017 The Apache Software Foundation. All rights reserved.