public class HiveIcebergInputFormat extends MapredIcebergInputFormat<Record> implements org.apache.hadoop.hive.ql.io.CombineHiveInputFormat.AvoidSplitCombination, org.apache.hadoop.hive.ql.exec.vector.VectorizedInputFormatInterface
MapredIcebergInputFormat.CompatibilityTaskAttemptContextImpl
Constructor and Description |
---|
HiveIcebergInputFormat() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapred.RecordReader<java.lang.Void,Container<Record>> |
getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.Reporter reporter) |
org.apache.hadoop.mapred.InputSplit[] |
getSplits(org.apache.hadoop.mapred.JobConf job,
int numSplits) |
VectorizedSupport.Support[] |
getSupportedFeatures() |
boolean |
shouldSkipCombine(org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration conf) |
configure, newTaskAttemptContext
public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits) throws java.io.IOException
getSplits
in interface org.apache.hadoop.mapred.InputFormat<java.lang.Void,Container<Record>>
getSplits
in class MapredIcebergInputFormat<Record>
java.io.IOException
public org.apache.hadoop.mapred.RecordReader<java.lang.Void,Container<Record>> getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter) throws java.io.IOException
getRecordReader
in interface org.apache.hadoop.mapred.InputFormat<java.lang.Void,Container<Record>>
getRecordReader
in class MapredIcebergInputFormat<Record>
java.io.IOException
public boolean shouldSkipCombine(org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf)
shouldSkipCombine
in interface org.apache.hadoop.hive.ql.io.CombineHiveInputFormat.AvoidSplitCombination
public VectorizedSupport.Support[] getSupportedFeatures()