public class AvroGenericRecordReader
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected JobConf |
jobConf |
Constructor and Description |
---|
AvroGenericRecordReader(JobConf job,
FileSplit split,
Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(JobConf jobConf) |
NullWritable |
createKey() |
AvroGenericRecordWritable |
createValue() |
long |
getPos() |
float |
getProgress() |
boolean |
next(NullWritable nullWritable,
AvroGenericRecordWritable record) |
public AvroGenericRecordReader(JobConf job, FileSplit split, Reporter reporter) throws java.io.IOException
java.io.IOException
public boolean next(NullWritable nullWritable, AvroGenericRecordWritable record) throws java.io.IOException
java.io.IOException
public NullWritable createKey()
public AvroGenericRecordWritable createValue()
public long getPos() throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
java.io.IOException
public float getProgress() throws java.io.IOException
java.io.IOException
public void configure(JobConf jobConf)
Copyright © 2012 The Apache Software Foundation