Package fr.ens.biologie.genomique.eoulsan.bio.io.hadoop

Class CompressedSplitFastqLineReader

java.lang.Object

org.apache.hadoop.util.LineReader

org.apache.hadoop.mapreduce.lib.input.SplitLineReader

fr.ens.biologie.genomique.eoulsan.bio.io.hadoop.CompressedSplitFastqLineReader

All Implemented Interfaces:

Closeable, AutoCloseable

public class CompressedSplitFastqLineReader
extends org.apache.hadoop.mapreduce.lib.input.SplitLineReader

Constructor Summary

Constructors

Constructor	Description
CompressedSplitFastqLineReader(org.apache.hadoop.io.compress.SplitCompressionInputStream in, org.apache.hadoop.conf.Configuration conf, byte[] recordDelimiterBytes)

Method Summary

Modifier and Type	Method	Description
protected int	fillBuffer(InputStream in, byte[] buffer, boolean inDelimiter)
boolean	needAdditionalRecordAfterSplit()
int	readLine(org.apache.hadoop.io.Text str, int maxLineLength, int maxBytesToConsume)

Methods inherited from class org.apache.hadoop.util.LineReader

close, readLine, readLine

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CompressedSplitFastqLineReader

public CompressedSplitFastqLineReader(org.apache.hadoop.io.compress.SplitCompressionInputStream in,
                                      org.apache.hadoop.conf.Configuration conf,
                                      byte[] recordDelimiterBytes)
                               throws IOException

Throws:

IOException

Method Detail

fillBuffer

protected int fillBuffer(InputStream in,
                         byte[] buffer,
                         boolean inDelimiter)
                  throws IOException

Overrides:

fillBuffer in class org.apache.hadoop.util.LineReader

Throws:

IOException

readLine

public int readLine(org.apache.hadoop.io.Text str,
                    int maxLineLength,
                    int maxBytesToConsume)
             throws IOException

Overrides:

readLine in class org.apache.hadoop.util.LineReader

Throws:

IOException

needAdditionalRecordAfterSplit

public boolean needAdditionalRecordAfterSplit()

Overrides:

needAdditionalRecordAfterSplit in class org.apache.hadoop.mapreduce.lib.input.SplitLineReader