Package org.apache.sysds.runtime.util
Class BinaryBlockRecordReader
- java.lang.Object
- 
- org.apache.hadoop.mapred.SequenceFileRecordReader<MatrixIndexes,MatrixBlock>
- 
- org.apache.sysds.runtime.util.BinaryBlockRecordReader
 
 
- 
- All Implemented Interfaces:
- Closeable,- AutoCloseable,- org.apache.hadoop.mapred.RecordReader<MatrixIndexes,MatrixBlock>
 
 public class BinaryBlockRecordReader extends org.apache.hadoop.mapred.SequenceFileRecordReader<MatrixIndexes,MatrixBlock> Custom record reader for binary block. Currently its only purpose is to allow for detailed profiling of overall read time (io, deserialize, decompress). NOTE: not used by default.
- 
- 
Constructor SummaryConstructors Constructor Description BinaryBlockRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapred.FileSplit split)
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()booleannext(MatrixIndexes key, MatrixBlock value)
 
- 
- 
- 
Constructor Detail- 
BinaryBlockRecordReaderpublic BinaryBlockRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapred.FileSplit split) throws IOException- Throws:
- IOException
 
 
- 
 - 
Method Detail- 
nextpublic boolean next(MatrixIndexes key, MatrixBlock value) throws IOException - Specified by:
- nextin interface- org.apache.hadoop.mapred.RecordReader<MatrixIndexes,MatrixBlock>
- Overrides:
- nextin class- org.apache.hadoop.mapred.SequenceFileRecordReader<MatrixIndexes,MatrixBlock>
- Throws:
- IOException
 
 - 
closepublic void close() throws IOException- Specified by:
- closein interface- AutoCloseable
- Specified by:
- closein interface- Closeable
- Specified by:
- closein interface- org.apache.hadoop.mapred.RecordReader<MatrixIndexes,MatrixBlock>
- Overrides:
- closein class- org.apache.hadoop.mapred.SequenceFileRecordReader<MatrixIndexes,MatrixBlock>
- Throws:
- IOException
 
 
- 
 
-