T
- The (java) type of data in Trevni container file.public class AvroTrevniKeyRecordReader<T> extends AvroTrevniRecordReaderBase<AvroKey<T>,NullWritable,T>
Constructor and Description |
---|
AvroTrevniKeyRecordReader() |
Modifier and Type | Method and Description |
---|---|
AvroKey<T> |
getCurrentKey() |
NullWritable |
getCurrentValue() |
boolean |
nextKeyValue() |
close, getCurrentRecord, getProgress, initialize
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
public boolean nextKeyValue() throws IOException, InterruptedException
nextKeyValue
in class AvroTrevniRecordReaderBase<AvroKey<T>,NullWritable,T>
IOException
InterruptedException
Copyright © 2009–2017 The Apache Software Foundation. All rights reserved.