Class IcebergPigInputFormat.IcebergRecordReader<T>

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable
    Enclosing class:
    IcebergPigInputFormat<T>

    public class IcebergPigInputFormat.IcebergRecordReader<T>
    extends org.apache.hadoop.mapreduce.RecordReader<java.lang.Void,​T>
    • Constructor Detail

      • IcebergRecordReader

        public IcebergRecordReader()
    • Method Detail

      • initialize

        public void initialize​(org.apache.hadoop.mapreduce.InputSplit split,
                               org.apache.hadoop.mapreduce.TaskAttemptContext initContext)
                        throws java.io.IOException
        Specified by:
        initialize in class org.apache.hadoop.mapreduce.RecordReader<java.lang.Void,​T>
        Throws:
        java.io.IOException
      • nextKeyValue

        public boolean nextKeyValue()
                             throws java.io.IOException
        Specified by:
        nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<java.lang.Void,​T>
        Throws:
        java.io.IOException
      • getCurrentKey

        public java.lang.Void getCurrentKey()
        Specified by:
        getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<java.lang.Void,​T>
      • getCurrentValue

        public T getCurrentValue()
        Specified by:
        getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<java.lang.Void,​T>
      • getProgress

        public float getProgress()
        Specified by:
        getProgress in class org.apache.hadoop.mapreduce.RecordReader<java.lang.Void,​T>
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Specified by:
        close in class org.apache.hadoop.mapreduce.RecordReader<java.lang.Void,​T>