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 Summary
Constructors Constructor Description BinaryBlockRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapred.FileSplit split)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()booleannext(MatrixIndexes key, MatrixBlock value)
-
-
-
Constructor Detail
-
BinaryBlockRecordReader
public BinaryBlockRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapred.FileSplit split) throws IOException- Throws:
IOException
-
-
Method Detail
-
next
public boolean next(MatrixIndexes key, MatrixBlock value) throws IOException
- Specified by:
nextin interfaceorg.apache.hadoop.mapred.RecordReader<MatrixIndexes,MatrixBlock>- Overrides:
nextin classorg.apache.hadoop.mapred.SequenceFileRecordReader<MatrixIndexes,MatrixBlock>- Throws:
IOException
-
close
public void close() throws IOException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceorg.apache.hadoop.mapred.RecordReader<MatrixIndexes,MatrixBlock>- Overrides:
closein classorg.apache.hadoop.mapred.SequenceFileRecordReader<MatrixIndexes,MatrixBlock>- Throws:
IOException
-
-