T
- The (java) type of data in Trevni container file.public class AvroTrevniKeyRecordReader<T> extends AvroTrevniRecordReaderBase<org.apache.avro.mapred.AvroKey<T>,org.apache.hadoop.io.NullWritable,T>
Constructor and Description |
---|
AvroTrevniKeyRecordReader() |
Modifier and Type | Method and Description |
---|---|
org.apache.avro.mapred.AvroKey<T> |
getCurrentKey() |
org.apache.hadoop.io.NullWritable |
getCurrentValue() |
boolean |
nextKeyValue() |
close, getCurrentRecord, getProgress, initialize
public org.apache.avro.mapred.AvroKey<T> getCurrentKey() throws IOException, InterruptedException
getCurrentKey
in class org.apache.hadoop.mapreduce.RecordReader<org.apache.avro.mapred.AvroKey<T>,org.apache.hadoop.io.NullWritable>
IOException
InterruptedException
public org.apache.hadoop.io.NullWritable getCurrentValue() throws IOException, InterruptedException
getCurrentValue
in class org.apache.hadoop.mapreduce.RecordReader<org.apache.avro.mapred.AvroKey<T>,org.apache.hadoop.io.NullWritable>
IOException
InterruptedException
public boolean nextKeyValue() throws IOException, InterruptedException
nextKeyValue
in class AvroTrevniRecordReaderBase<org.apache.avro.mapred.AvroKey<T>,org.apache.hadoop.io.NullWritable,T>
IOException
InterruptedException
Copyright © 2009–2020 Cloudera. All rights reserved.