Class FastqLineRecordReader

  • All Implemented Interfaces:
    Closeable, AutoCloseable

    public class FastqLineRecordReader
    extends org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Text>
    Treats keys as offset in file and value as line.
    • Constructor Detail

      • FastqLineRecordReader

        public FastqLineRecordReader()
      • FastqLineRecordReader

        public FastqLineRecordReader​(byte[] recordDelimiter)
    • Method Detail

      • initialize

        public void initialize​(org.apache.hadoop.mapreduce.InputSplit genericSplit,
                               org.apache.hadoop.mapreduce.TaskAttemptContext context)
                        throws IOException
        Specified by:
        initialize in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Text>
        Throws:
        IOException
      • nextKeyValue

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

        public org.apache.hadoop.io.LongWritable getCurrentKey()
        Specified by:
        getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Text>
      • getCurrentValue

        public org.apache.hadoop.io.Text getCurrentValue()
        Specified by:
        getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Text>
      • getProgress

        public float getProgress()
                          throws IOException
        Get the progress within the split
        Specified by:
        getProgress in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Text>
        Throws:
        IOException
      • close

        public void close()
                   throws IOException
        Specified by:
        close in interface AutoCloseable
        Specified by:
        close in interface Closeable
        Specified by:
        close in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Text>
        Throws:
        IOException