Class FastqRecordReader
- java.lang.Object
-
- org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
-
- fr.ens.biologie.genomique.eoulsan.bio.io.hadoop.FastqRecordReader
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
public class FastqRecordReader extends org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
This class define a RecordReader for FASTQ files for the Hadoop MapReduce framework.- Since:
- 1.0
- Author:
- Laurent Jourdren
-
-
Constructor Summary
Constructors Constructor Description FastqRecordReader(org.apache.hadoop.mapreduce.TaskAttemptContext context)
Public constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
org.apache.hadoop.io.Text
getCurrentKey()
org.apache.hadoop.io.Text
getCurrentValue()
float
getProgress()
void
initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext)
boolean
nextKeyValue()
-
-
-
Method Detail
-
close
public void close() throws IOException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in classorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
- Throws:
IOException
-
getCurrentKey
public org.apache.hadoop.io.Text getCurrentKey() throws IOException, InterruptedException
- Specified by:
getCurrentKey
in classorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
- Throws:
IOException
InterruptedException
-
getCurrentValue
public org.apache.hadoop.io.Text getCurrentValue() throws IOException, InterruptedException
- Specified by:
getCurrentValue
in classorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
- Throws:
IOException
InterruptedException
-
getProgress
public float getProgress() throws IOException, InterruptedException
- Specified by:
getProgress
in classorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
- Throws:
IOException
InterruptedException
-
initialize
public void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) throws IOException, InterruptedException
- Specified by:
initialize
in classorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
- Throws:
IOException
InterruptedException
-
nextKeyValue
public boolean nextKeyValue() throws IOException, InterruptedException
- Specified by:
nextKeyValue
in classorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
- Throws:
IOException
InterruptedException
-
-