Class LongLongRecordReader

  • All Implemented Interfaces:
    Closeable, AutoCloseable, org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,​LongLong>

    public class LongLongRecordReader
    extends Object
    implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,​LongLong>
    • Constructor Detail

      • LongLongRecordReader

        public LongLongRecordReader​(org.apache.hadoop.conf.Configuration job,
                                    org.apache.hadoop.mapred.FileSplit split,
                                    byte[] recordDelimiter)
                             throws IOException
        Throws:
        IOException
    • Method Detail

      • next

        public boolean next​(org.apache.hadoop.io.LongWritable longWritable,
                            LongLong longLong)
                     throws IOException
        Specified by:
        next in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,​LongLong>
        Throws:
        IOException
      • createKey

        public org.apache.hadoop.io.LongWritable createKey()
        Specified by:
        createKey in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,​LongLong>
      • createValue

        public LongLong createValue()
        Specified by:
        createValue in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,​LongLong>
      • getPos

        public long getPos()
                    throws IOException
        Specified by:
        getPos in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,​LongLong>
        Throws:
        IOException
      • getProgress

        public float getProgress()
                          throws IOException
        Specified by:
        getProgress in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,​LongLong>
        Throws:
        IOException