public class AvroRecordReader<T> extends Object implements RecordReader<AvroWrapper<T>,NullWritable>
RecordReader
for Avro data files.Modifier | Constructor and Description |
---|---|
protected |
AvroRecordReader(FileReader<T> reader,
FileSplit split) |
|
AvroRecordReader(JobConf job,
FileSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
AvroWrapper<T> |
createKey() |
NullWritable |
createValue() |
long |
getPos() |
float |
getProgress() |
boolean |
next(AvroWrapper<T> wrapper,
NullWritable ignore) |
public AvroRecordReader(JobConf job, FileSplit split) throws IOException
IOException
protected AvroRecordReader(FileReader<T> reader, FileSplit split) throws IOException
IOException
public AvroWrapper<T> createKey()
createKey
in interface RecordReader<AvroWrapper<T>,NullWritable>
public NullWritable createValue()
createValue
in interface RecordReader<AvroWrapper<T>,NullWritable>
public boolean next(AvroWrapper<T> wrapper, NullWritable ignore) throws IOException
next
in interface RecordReader<AvroWrapper<T>,NullWritable>
IOException
public float getProgress() throws IOException
getProgress
in interface RecordReader<AvroWrapper<T>,NullWritable>
IOException
public long getPos() throws IOException
getPos
in interface RecordReader<AvroWrapper<T>,NullWritable>
IOException
public void close() throws IOException
close
in interface RecordReader<AvroWrapper<T>,NullWritable>
IOException
Copyright © 2009–2017 The Apache Software Foundation. All rights reserved.