public class HiveIcebergInputFormat extends MapredIcebergInputFormat<Record> implements org.apache.hadoop.hive.ql.io.CombineHiveInputFormat.AvoidSplitCombination
Constructor and Description |
---|
HiveIcebergInputFormat() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapred.InputSplit[] |
getSplits(org.apache.hadoop.mapred.JobConf job,
int numSplits) |
boolean |
shouldSkipCombine(org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration conf) |
configure, getRecordReader
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 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