K
- The type of key the record reader should generate.V
- The type of value the record reader should generate.T
- The type of the entries within the Trevni container file being read.public abstract class AvroTrevniRecordReaderBase<K,V,T> extends RecordReader<K,V>
RecordReader
s that read Trevni container files.Constructor and Description |
---|
AvroTrevniRecordReaderBase() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected T |
getCurrentRecord()
Gets the current record read from the Trevni container file.
|
float |
getProgress() |
void |
initialize(InputSplit inputSplit,
TaskAttemptContext context) |
boolean |
nextKeyValue() |
getCurrentKey, getCurrentValue
public void initialize(InputSplit inputSplit, TaskAttemptContext context) throws IOException, InterruptedException
initialize
in class RecordReader<K,V>
IOException
InterruptedException
public boolean nextKeyValue() throws IOException, InterruptedException
nextKeyValue
in class RecordReader<K,V>
IOException
InterruptedException
protected T getCurrentRecord()
Calling nextKeyValue()
moves this to the next record.
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class RecordReader<K,V>
IOException
public float getProgress() throws IOException, InterruptedException
getProgress
in class RecordReader<K,V>
IOException
InterruptedException
Copyright © 2009–2017 The Apache Software Foundation. All rights reserved.