Class HiveIcebergInputFormat

  • All Implemented Interfaces:
    org.apache.hadoop.hive.ql.exec.vector.VectorizedInputFormatInterface, org.apache.hadoop.hive.ql.io.CombineHiveInputFormat.AvoidSplitCombination, org.apache.hadoop.mapred.InputFormat<java.lang.Void,​Container<Record>>

    public class HiveIcebergInputFormat
    extends MapredIcebergInputFormat<Record>
    implements org.apache.hadoop.hive.ql.io.CombineHiveInputFormat.AvoidSplitCombination, org.apache.hadoop.hive.ql.exec.vector.VectorizedInputFormatInterface
    • Constructor Detail

      • HiveIcebergInputFormat

        public HiveIcebergInputFormat()
    • Method Detail

      • getSplits

        public org.apache.hadoop.mapred.InputSplit[] getSplits​(org.apache.hadoop.mapred.JobConf job,
                                                               int numSplits)
                                                        throws java.io.IOException
        Specified by:
        getSplits in interface org.apache.hadoop.mapred.InputFormat<java.lang.Void,​Container<Record>>
        Overrides:
        getSplits in class MapredIcebergInputFormat<Record>
        Throws:
        java.io.IOException
      • getRecordReader

        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
        Specified by:
        getRecordReader in interface org.apache.hadoop.mapred.InputFormat<java.lang.Void,​Container<Record>>
        Overrides:
        getRecordReader in class MapredIcebergInputFormat<Record>
        Throws:
        java.io.IOException
      • shouldSkipCombine

        public boolean shouldSkipCombine​(org.apache.hadoop.fs.Path path,
                                         org.apache.hadoop.conf.Configuration conf)
        Specified by:
        shouldSkipCombine in interface org.apache.hadoop.hive.ql.io.CombineHiveInputFormat.AvoidSplitCombination