org.apache.sysml.runtime.compress

Class ColGroupDDC1

java.lang.Object

org.apache.sysml.runtime.compress.ColGroup

org.apache.sysml.runtime.compress.ColGroupValue

org.apache.sysml.runtime.compress.ColGroupDDC

org.apache.sysml.runtime.compress.ColGroupDDC1

All Implemented Interfaces:

Serializable

public class ColGroupDDC1
extends ColGroupDDC

Class to encapsulate information about a column group that is encoded with dense dictionary encoding (DDC) using 1 byte codes.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.sysml.runtime.compress.ColGroup

ColGroup.ColGroupRowIterator, ColGroup.CompressionType

Field Summary

Fields inherited from class org.apache.sysml.runtime.compress.ColGroupValue

_values, LOW_LEVEL_OPT, SORT_VALUES_BY_LENGTH

Fields inherited from class org.apache.sysml.runtime.compress.ColGroup

_colIndexes, _numRows

Constructor Summary

Constructors

Constructor and Description
ColGroupDDC1()
ColGroupDDC1(int[] colIndices, int numRows, double[] values, byte[] data)
ColGroupDDC1(int[] colIndices, int numRows, UncompressedBitmap ubm)

Method Summary

Modifier and Type	Method and Description
static void	computeRowSums(ColGroupDDC1[] grps, MatrixBlock result, org.apache.sysml.runtime.functionobjects.KahanFunction kplus, int rl, int ru)
protected void	computeRowSums(MatrixBlock result, org.apache.sysml.runtime.functionobjects.KahanFunction kplus, int rl, int ru)
protected void	computeSum(MatrixBlock result, org.apache.sysml.runtime.functionobjects.KahanFunction kplus)
protected void	countNonZerosPerRow(int[] rnnz, int rl, int ru) Count the number of non-zeros per row
void	decompressToBlock(MatrixBlock target, int colpos) Decompress to block.
void	decompressToBlock(MatrixBlock target, int rl, int ru) Decompress the contents of this column group into the specified full matrix block.
long	estimateInMemorySize() Note: Must be overridden by child classes to account for additional data and metadata
protected int	getCode(int r)
ColGroup.CompressionType	getCompType() Obtain the compression type.
int[]	getCounts(int[] counts)
int[]	getCounts(int rl, int ru, int[] counts)
protected double	getData(int r) Generic get value for byte-length-agnostic access to first column.
protected double	getData(int r, int colIx) Generic get value for byte-length-agnostic access.
long	getExactSizeOnDisk() Returns the exact serialized size of column group.
void	leftMultByRowVector(ColGroupDDC a, MatrixBlock result)
void	leftMultByRowVector(MatrixBlock vector, MatrixBlock result) Multiply the slice of the matrix that this column group represents by a row vector on the left (the original column vector is assumed to be transposed already i.e.
void	readFields(DataInput in) Deserializes column group from data input.
void	readFields(DataInput in, boolean skipDict) Deserializes column group from data input.
void	recodeData(HashMap<Double,Integer> map)
static void	rightMultByVector(ColGroupDDC1[] grps, MatrixBlock vector, MatrixBlock result, int rl, int ru)
void	rightMultByVector(MatrixBlock vector, MatrixBlock result, int rl, int ru) Multiply the slice of the matrix that this column group represents by a vector on the right.
ColGroup	scalarOperation(org.apache.sysml.runtime.matrix.operators.ScalarOperator op) Perform the specified scalar operation directly on the compressed column group, without decompressing individual cells if possible.
protected void	setData(int r, int code) Generic set value for byte-length-agnostic write of encoded value.
void	write(DataOutput out) Serializes column group to data output.
void	write(DataOutput out, boolean skipDict) Serializes column group to data output.

Methods inherited from class org.apache.sysml.runtime.compress.ColGroupDDC

computeColSums, computeRowMxx, decompressToBlock, get, getIterator, getRowIterator, postScaling, unaryAggregateOperations

Methods inherited from class org.apache.sysml.runtime.compress.ColGroupValue

allocDVector, allocIVector, applyScalarOp, applyScalarOp, cleanupThreadLocalMemory, computeColMxx, computeMxx, containsAllZeroValue, getCounts, getCounts, getCounts, getCountsAsBlock, getCountsAsBlock, getNumValues, getValue, getValues, getValuesAsBlock, getValuesSize, preaggValues, preaggValues, setupThreadLocalMemory, setValues, sumAllValues, sumAllValues, sumValues, sumValues, sumValues, sumValues, unaryAggregateOperations

Methods inherited from class org.apache.sysml.runtime.compress.ColGroup

getColIndex, getColIndices, getNumCols, getNumRows, shiftColIndices

Methods inherited from class java.lang.Object

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

Constructor Detail

ColGroupDDC1

public ColGroupDDC1()

ColGroupDDC1

public ColGroupDDC1(int[] colIndices,
                    int numRows,
                    UncompressedBitmap ubm)

ColGroupDDC1

public ColGroupDDC1(int[] colIndices,
                    int numRows,
                    double[] values,
                    byte[] data)

Method Detail

getCompType

public ColGroup.CompressionType getCompType()

Description copied from class: ColGroup

Obtain the compression type.

Specified by:

getCompType in class ColGroup

Returns:

How the elements of the column group are compressed.

getData

protected double getData(int r)

Description copied from class: ColGroupDDC

Generic get value for byte-length-agnostic access to first column.

Specified by:

getData in class ColGroupDDC

Parameters:

r - global row index

Returns:

value

getData

protected double getData(int r,
                         int colIx)

Description copied from class: ColGroupDDC

Generic get value for byte-length-agnostic access.

Specified by:

getData in class ColGroupDDC

Parameters:

r - global row index

colIx - local column index

Returns:

value

setData

protected void setData(int r,
                       int code)

Description copied from class: ColGroupDDC

Generic set value for byte-length-agnostic write of encoded value.

Specified by:

setData in class ColGroupDDC

Parameters:

r - global row index

code - encoded value

getCode

protected int getCode(int r)

Specified by:

getCode in class ColGroupDDC

recodeData

public void recodeData(HashMap<Double,Integer> map)

write

public void write(DataOutput out)
           throws IOException

Description copied from class: ColGroup

Serializes column group to data output.

Specified by:

write in class ColGroup

Parameters:

out - data output

Throws:

IOException - if IOException occurs

write

public void write(DataOutput out,
                  boolean skipDict)
           throws IOException

Description copied from class: ColGroup

Serializes column group to data output.

Overrides:

write in class ColGroup

Parameters:

out - data output

skipDict - skip shared dictionary

Throws:

IOException - if IOException occurs

readFields

public void readFields(DataInput in)
                throws IOException

Description copied from class: ColGroup

Deserializes column group from data input.

Specified by:

readFields in class ColGroup

Parameters:

in - data input

Throws:

IOException - if IOException occurs

readFields

public void readFields(DataInput in,
                       boolean skipDict)
                throws IOException

Description copied from class: ColGroup

Deserializes column group from data input.

Overrides:

readFields in class ColGroup

Parameters:

in - data input

skipDict - skip shared dictionary

Throws:

IOException - if IOException occurs

getExactSizeOnDisk

public long getExactSizeOnDisk()

Description copied from class: ColGroup

Returns the exact serialized size of column group. This can be used for example for buffer preallocation.

Specified by:

getExactSizeOnDisk in class ColGroup

Returns:

exact serialized size for column group

estimateInMemorySize

public long estimateInMemorySize()

Description copied from class: ColGroup

Note: Must be overridden by child classes to account for additional data and metadata

Overrides:

estimateInMemorySize in class ColGroupDDC

Returns:

an upper bound on the number of bytes used to store this ColGroup in memory.

decompressToBlock

public void decompressToBlock(MatrixBlock target,
                              int rl,
                              int ru)

Description copied from class: ColGroup

Decompress the contents of this column group into the specified full matrix block.

Overrides:

decompressToBlock in class ColGroupDDC

Parameters:

target - a matrix block where the columns covered by this column group have not yet been filled in.

rl - row lower

ru - row upper

decompressToBlock

public void decompressToBlock(MatrixBlock target,
                              int colpos)

Description copied from class: ColGroup

Decompress to block.

Overrides:

decompressToBlock in class ColGroupDDC

Parameters:

target - dense output vector

colpos - column to decompress, error if larger or equal numCols

getCounts

public int[] getCounts(int[] counts)

Specified by:

getCounts in class ColGroupValue

getCounts

public int[] getCounts(int rl,
                       int ru,
                       int[] counts)

Specified by:

getCounts in class ColGroupValue

countNonZerosPerRow

protected void countNonZerosPerRow(int[] rnnz,
                                   int rl,
                                   int ru)

Description copied from class: ColGroup

Count the number of non-zeros per row

Overrides:

countNonZerosPerRow in class ColGroupDDC

Parameters:

rnnz - non-zeros per row

rl - row lower bound, inclusive

ru - row upper bound, exclusive

rightMultByVector

public void rightMultByVector(MatrixBlock vector,
                              MatrixBlock result,
                              int rl,
                              int ru)

Description copied from class: ColGroup

Multiply the slice of the matrix that this column group represents by a vector on the right.

Specified by:

rightMultByVector in class ColGroup

Parameters:

vector - vector to multiply by (tall vector)

result - accumulator for holding the result

rl - row lower

ru - row upper if the internal SystemML code that performs the multiplication experiences an error

rightMultByVector

public static void rightMultByVector(ColGroupDDC1[] grps,
                                     MatrixBlock vector,
                                     MatrixBlock result,
                                     int rl,
                                     int ru)

leftMultByRowVector

public void leftMultByRowVector(MatrixBlock vector,
                                MatrixBlock result)

Description copied from class: ColGroup

Multiply the slice of the matrix that this column group represents by a row vector on the left (the original column vector is assumed to be transposed already i.e. its size now is 1xn).

Specified by:

leftMultByRowVector in class ColGroup

Parameters:

vector - row vector

result - matrix block result

leftMultByRowVector

public void leftMultByRowVector(ColGroupDDC a,
                                MatrixBlock result)

Specified by:

leftMultByRowVector in class ColGroupValue

computeSum

protected void computeSum(MatrixBlock result,
                          org.apache.sysml.runtime.functionobjects.KahanFunction kplus)

Overrides:

computeSum in class ColGroupDDC

computeRowSums

protected void computeRowSums(MatrixBlock result,
                              org.apache.sysml.runtime.functionobjects.KahanFunction kplus,
                              int rl,
                              int ru)

Overrides:

computeRowSums in class ColGroupDDC

computeRowSums

public static void computeRowSums(ColGroupDDC1[] grps,
                                  MatrixBlock result,
                                  org.apache.sysml.runtime.functionobjects.KahanFunction kplus,
                                  int rl,
                                  int ru)

scalarOperation

public ColGroup scalarOperation(org.apache.sysml.runtime.matrix.operators.ScalarOperator op)

Description copied from class: ColGroup

Perform the specified scalar operation directly on the compressed column group, without decompressing individual cells if possible.

Specified by:

scalarOperation in class ColGroup

Parameters:

op - operation to perform

Returns:

version of this column group with the operation applied