Class HiveIcebergSplit

java.lang.Object
org.apache.hadoop.mapreduce.InputSplit
org.apache.hadoop.mapred.FileSplit
org.apache.iceberg.mr.hive.HiveIcebergSplit
All Implemented Interfaces:
org.apache.hadoop.io.Writable, org.apache.hadoop.mapred.InputSplit, org.apache.hadoop.mapred.InputSplitWithLocationInfo, IcebergSplitContainer

public class HiveIcebergSplit extends org.apache.hadoop.mapred.FileSplit implements IcebergSplitContainer
  • Constructor Details

    • HiveIcebergSplit

      public HiveIcebergSplit()
  • Method Details

    • icebergSplit

      public IcebergSplit icebergSplit()
      Specified by:
      icebergSplit in interface IcebergSplitContainer
    • getLength

      public long getLength()
      Specified by:
      getLength in interface org.apache.hadoop.mapred.InputSplit
      Overrides:
      getLength in class org.apache.hadoop.mapred.FileSplit
    • getLocations

      public String[] getLocations()
      Specified by:
      getLocations in interface org.apache.hadoop.mapred.InputSplit
      Overrides:
      getLocations in class org.apache.hadoop.mapred.FileSplit
    • getPath

      public org.apache.hadoop.fs.Path getPath()
      Overrides:
      getPath in class org.apache.hadoop.mapred.FileSplit
    • getStart

      public long getStart()
      Overrides:
      getStart in class org.apache.hadoop.mapred.FileSplit
    • write

      public void write(DataOutput out) throws IOException
      Specified by:
      write in interface org.apache.hadoop.io.Writable
      Overrides:
      write in class org.apache.hadoop.mapred.FileSplit
      Throws:
      IOException
    • readFields

      public void readFields(DataInput in) throws IOException
      Specified by:
      readFields in interface org.apache.hadoop.io.Writable
      Overrides:
      readFields in class org.apache.hadoop.mapred.FileSplit
      Throws:
      IOException