org.apache.iceberg.mr.mapred

Class AbstractMapredIcebergRecordReader<T>

java.lang.Object

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

All Implemented Interfaces:

org.apache.hadoop.mapred.RecordReader<java.lang.Void,T>

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

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
java.lang.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 Detail

innerReader

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

Constructor Detail

AbstractMapredIcebergRecordReader

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

Throws:

java.io.IOException

Method Detail

createKey

public java.lang.Void createKey()

Specified by:

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

getProgress

public float getProgress()
                  throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException