Class CompressedMatrixBlockFactory
- java.lang.Object
- 
- org.apache.sysds.runtime.compress.CompressedMatrixBlockFactory
 
- 
 public class CompressedMatrixBlockFactory extends Object Factory pattern to compress a Matrix Block into a CompressedMatrixBlock.
- 
- 
Method SummaryAll Methods Static Methods Concrete Methods Modifier and Type Method Description static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb)Default sequential compression with no parallelizationstatic org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, int k)static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, int k, CompressionSettingsBuilder compSettings)static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, int k, CompressionSettingsBuilder compSettings, ACostEstimate costEstimator)static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, int k, CompressionSettingsBuilder compSettings, CostEstimatorBuilder csb)The main method for compressing the input matrix.static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, int k, CompressionSettingsBuilder compSettings, WTreeRoot root)The main method for compressing the input matrix.static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, int k, ACostEstimate costEstimator)static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, int k, CostEstimatorBuilder csb)static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, int k, InstructionTypeCounter ins)static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, int k, WTreeRoot root)static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, CompressionSettingsBuilder customSettings)static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, ACostEstimate costEstimator)static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, CostEstimatorBuilder csb)static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, InstructionTypeCounter ins)static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics>compress(MatrixBlock mb, WTreeRoot root)static voidcompressAsync(ExecutionContext ec, String varName)static voidcompressAsync(ExecutionContext ec, String varName, InstructionTypeCounter ins)static CompressedMatrixBlockcreateConstant(int numRows, int numCols, double value)Method for constructing a compressed matrix out of an constant input.static CompressedMatrixBlockgenUncompressedCompressedMatrixBlock(MatrixBlock mb)Generate a CompressedMatrixBlock Object that contains a single uncompressed matrix block column group.
 
- 
- 
- 
Method Detail- 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb) Default sequential compression with no parallelization- Parameters:
- mb- The matrixBlock to compress
- Returns:
- A Pair of a Matrix Block and Compression Statistics.
 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, WTreeRoot root) 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, CostEstimatorBuilder csb) 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, InstructionTypeCounter ins) 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, CompressionSettingsBuilder customSettings) 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, int k) 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, int k, WTreeRoot root) 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, int k, CostEstimatorBuilder csb) 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, int k, InstructionTypeCounter ins) 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, ACostEstimate costEstimator) 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, int k, ACostEstimate costEstimator) 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, int k, CompressionSettingsBuilder compSettings) 
 - 
compressAsyncpublic static void compressAsync(ExecutionContext ec, String varName) 
 - 
compressAsyncpublic static void compressAsync(ExecutionContext ec, String varName, InstructionTypeCounter ins) 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, int k, CompressionSettingsBuilder compSettings, WTreeRoot root) The main method for compressing the input matrix.- Parameters:
- mb- The matrix block to compress
- k- The number of threads used to execute the compression
- compSettings- The Compression settings used
- root- The root instruction compressed, and used for calculating the computation cost of the compression
- Returns:
- A pair of an possibly compressed matrix block and compression statistics.
 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, int k, CompressionSettingsBuilder compSettings, CostEstimatorBuilder csb) The main method for compressing the input matrix.- Parameters:
- mb- The matrix block to compress
- k- The number of threads used to execute the compression
- compSettings- The Compression settings used
- csb- The cost estimation builder
- Returns:
- A pair of an possibly compressed matrix block and compression statistics.
 
 - 
compresspublic static org.apache.commons.lang3.tuple.Pair<MatrixBlock,CompressionStatistics> compress(MatrixBlock mb, int k, CompressionSettingsBuilder compSettings, ACostEstimate costEstimator) 
 - 
genUncompressedCompressedMatrixBlockpublic static CompressedMatrixBlock genUncompressedCompressedMatrixBlock(MatrixBlock mb) Generate a CompressedMatrixBlock Object that contains a single uncompressed matrix block column group.- Parameters:
- mb- The matrix block to be contained in the uncompressed matrix block column,
- Returns:
- a CompressedMatrixBlock
 
 - 
createConstantpublic static CompressedMatrixBlock createConstant(int numRows, int numCols, double value) Method for constructing a compressed matrix out of an constant input. Since the input is a constant value it is trivially compressable, therefore we skip the entire compression planning and directly return a compressed constant matrix- Parameters:
- numRows- The number of Rows in the matrix
- numCols- The number of Columns in the matrix
- value- The value contained in the matrix
- Returns:
- The Compressed Constant matrix.
 
 
- 
 
-