public abstract class AbstractMapredIcebergRecordReader<T>
extends java.lang.Object
implements org.apache.hadoop.mapred.RecordReader<java.lang.Void,T>
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.mapreduce.RecordReader<java.lang.Void,?> |
innerReader |
Constructor and Description |
---|
AbstractMapredIcebergRecordReader(IcebergInputFormat<?> mapreduceInputFormat,
IcebergSplit split,
org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.lang.Void |
createKey() |
float |
getProgress() |
protected final org.apache.hadoop.mapreduce.RecordReader<java.lang.Void,?> innerReader
public AbstractMapredIcebergRecordReader(IcebergInputFormat<?> mapreduceInputFormat, IcebergSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter) throws java.io.IOException
java.io.IOException
public java.lang.Void createKey()
createKey
in interface org.apache.hadoop.mapred.RecordReader<java.lang.Void,T>
public float getProgress() throws java.io.IOException
getProgress
in interface org.apache.hadoop.mapred.RecordReader<java.lang.Void,T>
java.io.IOException
public void close() throws java.io.IOException
close
in interface org.apache.hadoop.mapred.RecordReader<java.lang.Void,T>
java.io.IOException