SparseBlockMCSC (Apache SystemDS 3.4.0-SNAPSHOT API)
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description classSparseBlockMCSC.NonEmptyColumnsIteratorMCSCclassSparseBlockMCSC.NonEmptyRowsIteratorMCSC-
Nested classes/interfaces inherited from class org.apache.sysds.runtime.data.SparseBlock
SparseBlock.Type
-
-
Constructor Summary
Constructors Constructor Description SparseBlockMCSC(int clen)SparseBlockMCSC(int rlen, int clen)SparseBlockMCSC(SparseBlock sblock)SparseBlockMCSC(SparseBlock sblock, int clen)SparseBlockMCSC(SparseRow[] cols, boolean deep, int rlen)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanadd(int r, int c, double v)Add a value to a matrix cell (r,c).
voidallocate(int r)Allocate the underlying data structure holding non-zero values of row r if necessary.
voidallocate(int r, int nnz)Allocate the underlying data structure holding non-zero values of row r if necessary, w/ given size.
voidallocate(int r, int ennz, int maxnnz)Allocate the underlying data structure holding non-zero values of row r w/ the specified estimated nnz and max nnz.
voidallocateCol(int c)voidallocateCol(int c, int nnz)voidallocateCol(int c, int ennz, int maxnnz)voidappend(int r, int c, double v)Append a value to the end of the physical representation.
booleancheckValidity(int rlen, int clen, long nnz, boolean strict)Validate the correctness of the internal data structures of the different sparse block implementations.
voidcompact(int r)Re-allocate physical row if physical size exceeds logical size plus resize factor.
voidcompactCol(int c)voiddeleteIndexRange(int r, int cl, int cu)Deletes all non-zero values of the given column range [cl,cu) in row r.
voiddeleteIndexRangeCol(int c, int rl, int ru)static longestimateSizeInMemory(long nrows, long ncols, double sparsity)Get the estimated in-memory size of the sparse block in MCSC with the given dimensions w/o accounting for overallocation.
SparseRowget(int r)Get values of row r in the format of a sparse row.
doubleget(int r, int c)Get value of matrix cell (r,c).
SparseRowgetCol(int c)SparseRow[]getCols()Helper function for MCSC
longgetExactSizeInMemory()Computes the exact size in memory of the materialized block
Iterator<Integer>getNonEmptyColumnsIterator(int cl, int cu)Iterator<Integer>getNonEmptyRowsIterator(int rl, int ru)SparseRow[]getRows()Helper function for MCSC
int[]indexes(int r)Get the sorted array of column indexes of all non-zero entries in row r.
int[]indexesCol(int c)booleanisAllocated(int r)Indicates if the underlying data structure for a given row is already allocated.
booleanisAllocatedCol(int c)booleanisContiguous()Indicates if the underlying data structures returned by values and indexes are contiguous arrays, which can be exploited for more efficient operations.
booleanisEmpty(int r)Get information if row r is empty, i.e., does not contain non-zero values.
booleanisEmptyCol(int c)booleanisThreadSafe()Indicates if the underlying implementation allows thread-safe row updates if concurrent threads update disjoint rows.
intnumCols()intnumRows()Get the number of rows in the sparse block.
intpos(int r)Get the starting position of row r in the indexes/values arrays returned by indexes(r) and values(r).
intposFIndexGT(int r, int c)Get position of first column index greater than column c in row r.
intposFIndexGTCol(int r, int c)intposFIndexGTE(int r, int c)Get position of first column index greater than or equal column c in row r.
intposFIndexGTECol(int r, int c)intposFIndexLTE(int r, int c)Get position of first column index lower than or equal column c in row r.
intposFIndexLTECol(int r, int c)voidreset()Clears the sparse block by deleting non-zero values.
voidreset(int ennz, int maxnnz)Clears the sparse block by deleting non-zero values.
voidreset(int r, int ennz, int maxnnz)Clears row r of the sparse block by deleting non-zero values.
voidresetCol(int c, int ennz, int maxnnz)booleanset(int r, int c, double v)Set the value of a matrix cell (r,c).
voidset(int r, SparseRow row, boolean deep)Set the values of row r to the given sparse row.
voidsetCol(int c, SparseRow col, boolean deep)voidsetIndexRange(int r, int cl, int cu, double[] v, int[] vix, int vpos, int vlen)Sets a sparse array of non-zeros values and indexes into the column range [cl,cu) in row r.
voidsetIndexRange(int r, int cl, int cu, double[] v, int vix, int vlen)Sets a dense array of non-zeros values into the column range [cl,cu) in row r.
voidsetIndexRangeCol(int c, int rl, int ru, double[] v, int[] vix, int vpos, int vlen)voidsetIndexRangeCol(int c, int rl, int ru, double[] v, int vix, int vlen)longsize()Get the number of non-zero values in the sparse block.
intsize(int r)Get the number of non-zero values in row r.
longsize(int rl, int ru)Get the number of non-zeros values in the row range of [rl, ru).
longsize(int rl, int ru, int cl, int cu)Get the number of non-zeros values in the row and column range of [rl/cl, ru/cu);
intsizeCol(int c)longsizeCol(int cl, int cu)voidsort()Sort all non-zero value/index pairs of the sparse block by row and column index.
voidsort(int r)Sort all non-zero value/index pairs of row r column index.
voidsortCol(int c)StringtoString()double[]values(int r)Get the array of all non-zero entries in row r, sorted by their column indexes.
double[]valuesCol(int c)-
Methods inherited from class org.apache.sysds.runtime.data.SparseBlock
contains, contains, equals, equals, equals, equals, getIterator, getIterator, getIterator, getIterator, getNonEmptyRows, getNonEmptyRows, isAligned, isAligned
-
-
-
-
Constructor Detail
-
SparseBlockMCSC
public SparseBlockMCSC(SparseBlock sblock, int clen)
-
SparseBlockMCSC
public SparseBlockMCSC(SparseBlock sblock)
-
SparseBlockMCSC
public SparseBlockMCSC(SparseRow[] cols, boolean deep, int rlen)
-
SparseBlockMCSC
public SparseBlockMCSC(int clen)
-
SparseBlockMCSC
public SparseBlockMCSC(int rlen, int clen)
-
-
Method Detail
-
estimateSizeInMemory
public static long estimateSizeInMemory(long nrows, long ncols, double sparsity)Get the estimated in-memory size of the sparse block in MCSC with the given dimensions w/o accounting for overallocation.
- Parameters:
nrows- number of rowsncols- number of columnssparsity- sparsity ratio- Returns:
- memory estimate
-
getExactSizeInMemory
public long getExactSizeInMemory()
Computes the exact size in memory of the materialized block
- Specified by:
getExactSizeInMemoryin classSparseBlock- Returns:
- the exact size in memory
-
allocate
public void allocate(int r)
Allocate the underlying data structure holding non-zero values of row r if necessary.
- Specified by:
allocatein classSparseBlock- Parameters:
r- row index
-
allocateCol
public void allocateCol(int c)
-
allocate
public void allocate(int r, int nnz)Allocate the underlying data structure holding non-zero values of row r if necessary, w/ given size.
- Specified by:
allocatein classSparseBlock- Parameters:
r- row indexnnz- number of non-zeros
-
allocateCol
public void allocateCol(int c, int nnz)
-
allocate
public void allocate(int r, int ennz, int maxnnz)Allocate the underlying data structure holding non-zero values of row r w/ the specified estimated nnz and max nnz.
- Specified by:
allocatein classSparseBlock- Parameters:
r- row indexennz- estimated non-zerosmaxnnz- max non-zeros
-
allocateCol
public void allocateCol(int c, int ennz, int maxnnz)
-
compact
public void compact(int r)
Re-allocate physical row if physical size exceeds logical size plus resize factor.
- Specified by:
compactin classSparseBlock- Parameters:
r- row index
-
compactCol
public void compactCol(int c)
-
numRows
public int numRows()
Get the number of rows in the sparse block.
- Specified by:
numRowsin classSparseBlock- Returns:
- number of rows
-
numCols
public int numCols()
-
isThreadSafe
public boolean isThreadSafe()
Indicates if the underlying implementation allows thread-safe row updates if concurrent threads update disjoint rows.
- Specified by:
isThreadSafein classSparseBlock- Returns:
- true if thread-safe row updates
-
isContiguous
public boolean isContiguous()
Indicates if the underlying data structures returned by values and indexes are contiguous arrays, which can be exploited for more efficient operations.
- Specified by:
isContiguousin classSparseBlock- Returns:
- true if underlying data structures are contiguous arrays
-
isAllocated
public boolean isAllocated(int r)
Indicates if the underlying data structure for a given row is already allocated.
- Specified by:
isAllocatedin classSparseBlock- Parameters:
r- row index- Returns:
- true if already allocated
-
isAllocatedCol
public boolean isAllocatedCol(int c)
-
reset
public void reset()
Clears the sparse block by deleting non-zero values. After this call all size() calls are guaranteed to return 0.
- Specified by:
resetin classSparseBlock
-
reset
public void reset(int ennz, int maxnnz)Clears the sparse block by deleting non-zero values. After this call all size() calls are guaranteed to return 0.
- Specified by:
resetin classSparseBlock- Parameters:
ennz- estimated non-zerosmaxnnz- max non-zeros
-
reset
public void reset(int r, int ennz, int maxnnz)Clears row r of the sparse block by deleting non-zero values. After this call size(r) is guaranteed to return 0.
- Specified by:
resetin classSparseBlock- Parameters:
r- row indexennz- estimated non-zerosmaxnnz- max non-zeros
-
resetCol
public void resetCol(int c, int ennz, int maxnnz)
-
size
public long size()
Get the number of non-zero values in the sparse block.
- Specified by:
sizein classSparseBlock- Returns:
- number of non-zero values in sparse block
-
size
public int size(int r)
Get the number of non-zero values in row r.
- Specified by:
sizein classSparseBlock- Parameters:
r- row index starting at 0- Returns:
- number of non-zero values in row r
-
sizeCol
public int sizeCol(int c)
-
size
public long size(int rl, int ru)Get the number of non-zeros values in the row range of [rl, ru).
- Specified by:
sizein classSparseBlock- Parameters:
rl- row lower indexru- row upper index- Returns:
- number of non-zero values in the row range
-
sizeCol
public long sizeCol(int cl, int cu)
-
size
public long size(int rl, int ru, int cl, int cu)Get the number of non-zeros values in the row and column range of [rl/cl, ru/cu);
- Specified by:
sizein classSparseBlock- Parameters:
rl- row lower indexru- row upper indexcl- column lower indexcu- column upper index- Returns:
- number of non-zero values in the row and column range
-
isEmpty
public boolean isEmpty(int r)
Get information if row r is empty, i.e., does not contain non-zero values. Equivalent to size(r)==0. Users should do this check if it is unknown if the underlying row data structure is allocated.
- Specified by:
isEmptyin classSparseBlock- Parameters:
r- row index starting at 0- Returns:
- true if row does not contain non-zero values
-
isEmptyCol
public boolean isEmptyCol(int c)
-
checkValidity
public boolean checkValidity(int rlen, int clen, long nnz, boolean strict)Validate the correctness of the internal data structures of the different sparse block implementations.
- Specified by:
checkValidityin classSparseBlock- Parameters:
rlen- number of rowsclen- number of columnsnnz- number of non zerosstrict- enforce optional properties- Returns:
- true if the sparse block is valid wrt the corresponding format such as COO, CSR, MCSR.
-
indexes
public int[] indexes(int r)
Get the sorted array of column indexes of all non-zero entries in row r. Note that - for flexibility of the implementing format - the returned array may be larger, where the range for row r is given by [pos(r),pos(r)+size(r)).
- Specified by:
indexesin classSparseBlock- Parameters:
r- row index starting at 0- Returns:
- sorted array of column indexes
-
indexesCol
public int[] indexesCol(int c)
-
values
public double[] values(int r)
Get the array of all non-zero entries in row r, sorted by their column indexes. Note that - for flexibility of the implementing format - the returned array may be larger, where the range for row r is given by [pos(r),pos(r)+size(r)).
- Specified by:
valuesin classSparseBlock- Parameters:
r- row index starting at 0- Returns:
- array of all non-zero entries in row r sorted by column indexes
-
valuesCol
public double[] valuesCol(int c)
-
pos
public int pos(int r)
Get the starting position of row r in the indexes/values arrays returned by indexes(r) and values(r).
- Specified by:
posin classSparseBlock- Parameters:
r- row index starting at 0- Returns:
- starting position of row r
-
set
public boolean set(int r, int c, double v)Set the value of a matrix cell (r,c). This might update an existing non-zero value, insert a new non-zero value, or delete a non-zero value.
- Specified by:
setin classSparseBlock- Parameters:
r- row index starting at 0c- column index starting at 0v- zero or non-zero value- Returns:
- true, if number of non-zeros changed
-
set
public void set(int r, SparseRow row, boolean deep)Set the values of row r to the given sparse row. This might update existing non-zero values, insert a new row, or delete a row. NOTE: This method exists for incremental runtime integration and might be deleted in the future.
- Specified by:
setin classSparseBlock- Parameters:
r- row index starting at 0row- sparse rowdeep- indicator to create deep copy of sparse row
-
setCol
public void setCol(int c, SparseRow col, boolean deep)
-
add
public boolean add(int r, int c, double v)Add a value to a matrix cell (r,c). This might update an existing non-zero value, or insert a new non-zero value.
- Specified by:
addin classSparseBlock- Parameters:
r- row index starting at 0c- column index starting at 0v- zero or non-zero value- Returns:
- true, if number of non-zeros changed
-
append
public void append(int r, int c, double v)Append a value to the end of the physical representation. This should only be used for operations with sequential write pattern or if followed by a sort() operation. Note that this operation does not perform any matrix cell updates.
- Specified by:
appendin classSparseBlock- Parameters:
r- row index starting at 0c- column index starting at 0v- zero or non-zero value
-
setIndexRange
public void setIndexRange(int r, int cl, int cu, double[] v, int vix, int vlen)Sets a dense array of non-zeros values into the column range [cl,cu) in row r. The passed value array may be larger and the relevant range is given by [vix,vix+len).
- Specified by:
setIndexRangein classSparseBlock- Parameters:
r- row index starting at 0cl- lower column index starting at 0cu- upper column index starting at 0v- value arrayvix- start index in value arrayvlen- number of relevant values
-
setIndexRangeCol
public void setIndexRangeCol(int c, int rl, int ru, double[] v, int vix, int vlen)
-
setIndexRange
public void setIndexRange(int r, int cl, int cu, double[] v, int[] vix, int vpos, int vlen)Sets a sparse array of non-zeros values and indexes into the column range [cl,cu) in row r. The passed value array may be larger.
- Specified by:
setIndexRangein classSparseBlock- Parameters:
r- row index starting at 0cl- lower column index starting at 0cu- upper column index starting at 0v- value arrayvix- column index arrayvpos- start index in value and index arraysvlen- number of relevant values
-
setIndexRangeCol
public void setIndexRangeCol(int c, int rl, int ru, double[] v, int[] vix, int vpos, int vlen)
-
deleteIndexRange
public void deleteIndexRange(int r, int cl, int cu)Deletes all non-zero values of the given column range [cl,cu) in row r.
- Specified by:
deleteIndexRangein classSparseBlock- Parameters:
r- row index starting at 0cl- lower column index starting at 0cu- upper column index starting at 0
-
deleteIndexRangeCol
public void deleteIndexRangeCol(int c, int rl, int ru)
-
sort
public void sort()
Sort all non-zero value/index pairs of the sparse block by row and column index.
- Specified by:
sortin classSparseBlock
-
sort
public void sort(int r)
Sort all non-zero value/index pairs of row r column index.
- Specified by:
sortin classSparseBlock- Parameters:
r- row index starting at 0
-
sortCol
public void sortCol(int c)
-
get
public double get(int r, int c)Get value of matrix cell (r,c). In case of non existing values this call returns 0.
- Specified by:
getin interfaceBlock- Specified by:
getin classSparseBlock- Parameters:
r- row index starting at 0c- column index starting at 0- Returns:
- value of cell at position (r,c)
-
get
public SparseRow get(int r)
Get values of row r in the format of a sparse row.
- Specified by:
getin classSparseBlock- Parameters:
r- row index starting at 0- Returns:
- values of row r as a sparse row
-
getCol
public SparseRow getCol(int c)
-
posFIndexLTE
public int posFIndexLTE(int r, int c)Get position of first column index lower than or equal column c in row r. The position is relative to the indexes/values arrays returned by indexes(r) and values(r). If no such value exists, this call returns -1.
- Specified by:
posFIndexLTEin classSparseBlock- Parameters:
r- row index starting at 0c- column index starting at 0- Returns:
- position of the first column index lower than or equal to column c in row r
-
posFIndexLTECol
public int posFIndexLTECol(int r, int c)
-
posFIndexGTE
public int posFIndexGTE(int r, int c)Get position of first column index greater than or equal column c in row r. The position is relative to the indexes/values arrays returned by indexes(r) and values(r). If no such value exists, this call returns -1. Note if CSR the pos(r) is subtracted from the result.
- Specified by:
posFIndexGTEin classSparseBlock- Parameters:
r- row index starting at 0c- column index starting at 0- Returns:
- position of the first column index greater than or equal to column c in row r
-
posFIndexGTECol
public int posFIndexGTECol(int r, int c)
-
posFIndexGT
public int posFIndexGT(int r, int c)Get position of first column index greater than column c in row r. The position is relative to the indexes/values arrays returned by indexes(r) and values(r). If no such value exists, this call returns -1.
- Specified by:
posFIndexGTin classSparseBlock- Parameters:
r- row index starting at 0c- column index starting at 0- Returns:
- position of the first column index greater than column c in row r
-
posFIndexGTCol
public int posFIndexGTCol(int r, int c)
-
getNonEmptyRowsIterator
public Iterator<Integer> getNonEmptyRowsIterator(int rl, int ru)
- Specified by:
getNonEmptyRowsIteratorin classSparseBlock
-
toString
public String toString()
- Specified by:
toStringin classSparseBlock
-
getCols
public SparseRow[] getCols()
Helper function for MCSC
- Returns:
- the underlying array of columns
SparseRow
-
getRows
public SparseRow[] getRows()
Helper function for MCSC
- Returns:
- the corresponding array of rows
SparseRow
-
-