Package org.apache.sysds.runtime.controlprogram.caching

Class CacheDataInput

java.lang.Object

org.apache.sysds.runtime.controlprogram.caching.CacheDataInput

All Implemented Interfaces:

DataInput, MatrixBlockDataInput

public class CacheDataInput
extends Object
implements DataInput, MatrixBlockDataInput

Constructor Summary

Constructors

Constructor	Description
CacheDataInput(byte[] mem)

Method Summary

Modifier and Type	Method	Description
boolean	readBoolean()
byte	readByte()
char	readChar()
double	readDouble()
long	readDoubleArray(int len, double[] varr)	Reads the double array from the data input into the given dense block and returns the number of non-zeros.
float	readFloat()
void	readFully(byte[] b)
void	readFully(byte[] b, int off, int len)
int	readInt()
String	readLine()
long	readLong()
short	readShort()
long	readSparseRows(int rlen, long nnz, SparseBlock rows)	Reads the sparse rows array from the data input into a sparse block and returns the number of non-zeros.
int	readUnsignedByte()
int	readUnsignedShort()
String	readUTF()
int	skipBytes(int n)

Methods inherited from class java.lang.Object

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

Constructor Details

CacheDataInput

public CacheDataInput(byte[] mem)

Method Details

readFully

public void readFully(byte[] b)
               throws IOException

Specified by:

readFully in interface DataInput

Throws:

IOException

readFully

public void readFully(byte[] b,
 int off,
 int len)
               throws IOException

Specified by:

readFully in interface DataInput

Throws:

IOException

skipBytes

public int skipBytes(int n)
              throws IOException

Specified by:

skipBytes in interface DataInput

Throws:

IOException

readBoolean

public boolean readBoolean()
                    throws IOException

Specified by:

readBoolean in interface DataInput

Throws:

IOException

readByte

public byte readByte()
              throws IOException

Specified by:

readByte in interface DataInput

Throws:

IOException

readUnsignedByte

public int readUnsignedByte()
                     throws IOException

Specified by:

readUnsignedByte in interface DataInput

Throws:

IOException

readShort

public short readShort()
                throws IOException

Specified by:

readShort in interface DataInput

Throws:

IOException

readUnsignedShort

public int readUnsignedShort()
                      throws IOException

Specified by:

readUnsignedShort in interface DataInput

Throws:

IOException

readChar

public char readChar()
              throws IOException

Specified by:

readChar in interface DataInput

Throws:

IOException

readInt

public int readInt()
            throws IOException

Specified by:

readInt in interface DataInput

Throws:

IOException

readLong

public long readLong()
              throws IOException

Specified by:

readLong in interface DataInput

Throws:

IOException

readFloat

public float readFloat()
                throws IOException

Specified by:

readFloat in interface DataInput

Throws:

IOException

readDouble

public double readDouble()
                  throws IOException

Specified by:

readDouble in interface DataInput

Throws:

IOException

readLine

public String readLine()
                throws IOException

Specified by:

readLine in interface DataInput

Throws:

IOException

readUTF

public String readUTF()
               throws IOException

Specified by:

readUTF in interface DataInput

Throws:

IOException

readDoubleArray

public long readDoubleArray(int len,
 double[] varr)
                     throws IOException

Description copied from interface: MatrixBlockDataInput

Reads the double array from the data input into the given dense block and returns the number of non-zeros.

Specified by:

readDoubleArray in interface MatrixBlockDataInput

Parameters:

len - ?

varr - ?

Returns:

number of non-zeros

Throws:

IOException - if IOException occurs

readSparseRows

public long readSparseRows(int rlen,
 long nnz,
 SparseBlock rows)
                    throws IOException

Description copied from interface: MatrixBlockDataInput

Reads the sparse rows array from the data input into a sparse block and returns the number of non-zeros.

Specified by:

readSparseRows in interface MatrixBlockDataInput

Parameters:

rlen - number of rows

nnz - number of non-zeros

rows - sparse block

Returns:

number of non-zeros

Throws:

IOException - if IOExcepton occurs