Package org.apache.iceberg.mr.mapred

Class AbstractMapredIcebergRecordReader<T>

java.lang.Object

org.apache.iceberg.mr.mapred.AbstractMapredIcebergRecordReader<T>

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.mapred.RecordReader<Void,T>

public abstract class AbstractMapredIcebergRecordReader<T>
extends Object
implements org.apache.hadoop.mapred.RecordReader<Void,T>

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.hadoop.mapreduce.RecordReader<Void,?>	innerReader

Constructor Summary

Constructors

Constructor	Description
AbstractMapredIcebergRecordReader(IcebergInputFormat<?> mapreduceInputFormat, IcebergSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter)

Method Summary

Modifier and Type	Method	Description
void	close()
Void	createKey()
float	getProgress()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.mapred.RecordReader

createValue, getPos, next

Field Details

innerReader

protected final org.apache.hadoop.mapreduce.RecordReader<Void,?> innerReader

Constructor Details

AbstractMapredIcebergRecordReader

public AbstractMapredIcebergRecordReader(IcebergInputFormat<?> mapreduceInputFormat,
 IcebergSplit split,
 org.apache.hadoop.mapred.JobConf job,
 org.apache.hadoop.mapred.Reporter reporter)
                                  throws IOException

Throws:

IOException

Method Details

createKey

public Void createKey()

Specified by:

createKey in interface org.apache.hadoop.mapred.RecordReader<Void,T>

getProgress

public float getProgress()
                  throws IOException

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader<Void,T>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader<Void,T>

Throws:

IOException