Package org.apache.sysds.runtime.matrix.data

Interface MatrixBlockDataInput

  • All Known Implementing Classes:
    ByteBufferDataInput, CacheDataInput, FastBufferedDataInputStream
    public interface MatrixBlockDataInput
    Any data input that is intended to support fast deserialization / read of entire blocks should implement this interface. On read of a matrix block we check if the input stream is an implementation of this interface, if yes we let the implementation directly pass the entire block instead of value-by-value. Known implementation classes: - FastBufferedDataInputStream - CacheDataInput

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      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.
      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.

    • Method Detail

      • readDoubleArray

        long readDoubleArray​(int len,
                     double[] varr)
              throws IOException
        Reads the double array from the data input into the given dense block and returns the number of non-zeros.
        Parameters:
        len - ?
        varr - ?
        Returns:
        number of non-zeros
        Throws:
        IOException - if IOException occurs

      • readSparseRows

        long readSparseRows​(int rlen,
                    long nnz,
                    SparseBlock rows)
             throws IOException
        Reads the sparse rows array from the data input into a sparse block and returns the number of non-zeros.
        Parameters:
        rlen - number of rows
        nnz - number of non-zeros
        rows - sparse block
        Returns:
        number of non-zeros
        Throws:
        IOException - if IOExcepton occurs