Uses of Class
org.apache.sysds.runtime.compress.colgroup.AColGroup
Packages that use AColGroup
Package
Description
-
Uses of AColGroup in org.apache.sysds.runtime.compress
Methods in org.apache.sysds.runtime.compress that return AColGroupModifier and TypeMethodDescriptionCompressedMatrixBlock.getColGroupForColumn(int id) Get the column group allocated and associated with a specific column Id; There is some search involved in this since we do not know where to look for the column and which Column group contains the value.Methods in org.apache.sysds.runtime.compress that return types with arguments of type AColGroupModifier and TypeMethodDescriptionCompressedMatrixBlock.getColGroups()Get the column groups of this CompressedMatrixBlockMethods in org.apache.sysds.runtime.compress with parameters of type AColGroupModifier and TypeMethodDescriptionvoidCompressedMatrixBlock.allocateColGroup(AColGroup cg) Allocate the given column group and remove all references to old column groups.Method parameters in org.apache.sysds.runtime.compress with type arguments of type AColGroupModifier and TypeMethodDescriptionvoidCompressedMatrixBlock.allocateColGroupList(List<AColGroup> colGroups) Replace the column groups in this CompressedMatrixBlock with the given column groupsConstructor parameters in org.apache.sysds.runtime.compress with type arguments of type AColGroupModifierConstructorDescriptionCompressedMatrixBlock(int rl, int cl, long nnz, boolean overlapping, List<AColGroup> groups) Direct constructor with everything. -
Uses of AColGroup in org.apache.sysds.runtime.compress.colgroup
Subclasses of AColGroup in org.apache.sysds.runtime.compress.colgroupModifier and TypeClassDescriptionclassBase class for column groups encoded Encoded in a compressed manner.classBase class for column groups encoded with various types of bitmap encoding.classclassclassAbstract class for column group types that do not perform matrix Multiplication, and decompression for performance reasons but instead transforms into another type of column group type to perform that operation.classAbstract class for all the column groups that use preAggregation for Left matrix multiplications.classColumn group that sparsely encodes the dictionary values.classclassclassClass to encapsulate information about a column group that is encoded with dense dictionary encoding (DDC).classClass to encapsulate information about a column group that is encoded with dense dictionary encoding (DDC).classClass to encapsulate information about a column group that is encoded with dense dictionary encoding (DDC) whose mapping vector is additionally lzw compressed.classClass to encapsulate information about a column group that is first delta encoded then encoded with dense dictionary encoding (DeltaDDC).classclassclassClass to encapsulate information about a column group that is encoded with simple lists of offsets for each set of distinct values.classA group of columns compressed with a single run-length encoded bitmap.classColumn group that sparsely encodes the dictionary values.classColGroup for Patched Frame Of Reference.classColumn group that sparsely encodes the dictionary values.classColumn group that sparsely encodes the dictionary values.classColumn group that sparsely encodes the dictionary values.classColumn group type for columns that are stored as dense arrays of doubles.classSpecial sideways compressed column group not supposed to be used outside of the compressed transform encode.Methods in org.apache.sysds.runtime.compress.colgroup that return AColGroupModifier and TypeMethodDescriptionAColGroup.addVector(double[] v) Short hand add operator call on column group to add a row vector to the column groupabstract AColGroupAppend the other column group to this column group.static AColGroupAppend all column groups in the list provided together in one go allocating the output once.ColGroupConst.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupDDC.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupDDCFOR.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupDeltaDDC.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupEmpty.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupLinearFunctional.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupOLE.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupRLE.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupSDC.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupSDCFOR.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupSDCSingle.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupSDCSingleZeros.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupSDCZeros.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupUncompressed.appendNInternal(AColGroup[] g, int blen, int rlen) abstract AColGroupAColGroup.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) Perform a binary row operation.ColGroupConst.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupDDC.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupDDCFOR.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupDDCLZW.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupEmpty.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupLinearFunctional.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupOLE.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupRLE.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupSDC.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupSDCFOR.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupSDCSingle.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupSDCSingleZeros.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupSDCZeros.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupUncompressed.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupUncompressedArray.binaryRowOpLeft(BinaryOperator op, double[] v, boolean isRowSafe) abstract AColGroupAColGroup.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) Perform a binary row operation.ColGroupConst.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupDDC.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupDDCFOR.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupDDCLZW.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupEmpty.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupLinearFunctional.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupOLE.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupRLE.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupSDC.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupSDCFOR.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupSDCSingle.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupSDCSingleZeros.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupSDCZeros.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupUncompressed.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) ColGroupUncompressedArray.binaryRowOpRight(BinaryOperator op, double[] v, boolean isRowSafe) Combine this column group with anotherAColGroup.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) C bind the list of column groups with this column group.AColGroup.combineWithSameIndex(int nRow, int nCol, AColGroup right) C bind the given column group to this.ColGroupConst.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) ColGroupConst.combineWithSameIndex(int nRow, int nCol, AColGroup right) ColGroupDDCFOR.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) ColGroupDDCFOR.combineWithSameIndex(int nRow, int nCol, AColGroup right) ColGroupEmpty.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) ColGroupEmpty.combineWithSameIndex(int nRow, int nCol, AColGroup right) ColGroupUncompressed.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) ColGroupUncompressed.combineWithSameIndex(int nRow, int nCol, AColGroup right) ColGroupDDCLZW.convertToDDC()Converts the current ColGroupDDCLZW instance to a ColGroupDDC instance.ColGroupDDC.convertToDDCLZW()ColGroupDDC.convertToDeltaDDC()abstract AColGroupAColGroup.copyAndSet(IColIndex colIndexes) Copy the content of the column group with pointers to the previous content but with new column given Note this method does not verify if the colIndexes specified are valid and correct dimensions for the underlying column groups.final AColGroupADictBasedColGroup.copyAndSet(IDictionary newDictionary) This method copies the column group and sets the dictionary to another dictionary.final AColGroupADictBasedColGroup.copyAndSet(IColIndex colIndexes) ColGroupEmpty.copyAndSet(IColIndex colIndexes) ColGroupLinearFunctional.copyAndSet(IColIndex colIndexes) ColGroupUncompressed.copyAndSet(IColIndex colIndexes) ColGroupUncompressedArray.copyAndSet(IColIndex colIndexes) static AColGroupColGroupConst.create(double[] values) Generate a constant column group.static AColGroupColGroupConst.create(int numCols, double value) Generate a constant column group.static AColGroupColGroupConst.create(int numCols, IDictionary dict) Generate a constant column group.static AColGroupGenerate a constant column group.static AColGroupGenerate a constant column group.static AColGroupColGroupConst.create(IColIndex colIndices, IDictionary dict) Create constructor for a ColGroup Const this constructor ensures that if the dictionary input is empty an Empty column group is constructed.static AColGroupColGroupDDC.create(IColIndex colIndexes, IDictionary dict, AMapToData data, int[] cachedCounts) static AColGroupColGroupDDCFOR.create(IColIndex colIndexes, IDictionary dict, AMapToData data, int[] cachedCounts, double[] reference) static AColGroupColGroupDDCLZW.create(IColIndex colIndexes, IDictionary dict, AMapToData data, int[] cachedCounts) static AColGroupColGroupDeltaDDC.create(IColIndex colIndexes, IDictionary dict, AMapToData data, int[] cachedCounts) static AColGroupGenerate a linear functional column group.static AColGroupColGroupSDC.create(IColIndex colIndices, int numRows, IDictionary dict, double[] defaultTuple, AOffset offsets, AMapToData data, int[] cachedCounts) static AColGroupColGroupSDCFOR.create(IColIndex colIndexes, int numRows, IDictionary dict, AOffset offsets, AMapToData data, int[] cachedCounts, double[] reference) static AColGroupColGroupSDCSingle.create(IColIndex colIndexes, int numRows, IDictionary dict, double[] defaultTuple, AOffset offsets, int[] cachedCounts) static AColGroupColGroupSDCSingleZeros.create(IColIndex colIndices, int numRows, IDictionary dict, AOffset offsets, int[] cachedCounts) static AColGroupColGroupSDCZeros.create(IColIndex colIndices, int numRows, IDictionary dict, AOffset offsets, AMapToData data, int[] cachedCounts) static AColGroupColGroupUncompressed.create(IColIndex colIndexes, MatrixBlock rawBlock, boolean transposed) Main constructor for Uncompressed ColGroup.static AColGroupColGroupUncompressed.create(MatrixBlock data) static AColGroupColGroupUncompressed.create(MatrixBlock mb, IColIndex colIndexes) Create an Uncompressed Matrix Block, where the columns are offset by col indexes.static AColGroupColGroupUncompressed.createQuantized(IColIndex colIndexes, MatrixBlock rawBlock, boolean transposed, double[] scaleFactors) Main constructor for a quantization-fused uncompressed ColGroup.static AColGroupColGroupUncompressed.createQuantized(MatrixBlock mb, IColIndex colIndexes, double[] scaleFactors) Create ana quantization-fused uncompressed Matrix Block, where the columns are offset by col indexes.abstract AColGroupAMorphingMMColGroup.extractCommon(double[] constV) extract common value from group and return non morphing groupColGroupDDCFOR.extractCommon(double[] constV) ColGroupSDC.extractCommon(double[] constV) ColGroupSDCFOR.extractCommon(double[] constV) ColGroupSDCSingle.extractCommon(double[] constV) IFrameOfReferenceGroup.extractCommon(double[] constV) extract common value from group and return non morphing groupAColGroup.morph(AColGroup.CompressionType ct, int nRow) Recompress this column group into a new column group of the given type.ASDC.morph(AColGroup.CompressionType ct, int nRow) ASDCZero.morph(AColGroup.CompressionType ct, int nRow) ColGroupDDC.morph(AColGroup.CompressionType ct, int nRow) ColGroupSDC.morph(AColGroup.CompressionType ct, int nRow) ColGroupSDCZeros.morph(AColGroup.CompressionType ct, int nRow) ColGroupUncompressed.morph(AColGroup.CompressionType ct, int nRow) static AColGroupColGroupIO.readColGroup(DataInput in, int nRows) abstract AColGroupAColGroup.recompress()Recompress this column group into a new column group.ColGroupConst.recompress()ColGroupDDC.recompress()ColGroupDDCFOR.recompress()ColGroupDDCLZW.recompress()ColGroupEmpty.recompress()ColGroupLinearFunctional.recompress()ColGroupOLE.recompress()ColGroupRLE.recompress()ColGroupSDC.recompress()ColGroupSDCFOR.recompress()ColGroupSDCSingle.recompress()ColGroupSDCSingleZeros.recompress()ColGroupSDCZeros.recompress()ColGroupUncompressed.recompress()ColGroupUncompressedArray.recompress()abstract AColGroupAColGroup.reduceCols()Perform row sum on the internal dictionaries, and return the same index structure.ADictBasedColGroup.reduceCols()ColGroupEmpty.reduceCols()ColGroupLinearFunctional.reduceCols()ColGroupUncompressed.reduceCols()ColGroupUncompressedArray.reduceCols()AColGroup.removeEmptyCols(boolean[] selectV) Return a new column group containing only the selected columns in the given boolean vector.abstract AColGroupAColGroup.removeEmptyRows(boolean[] selectV, int rOut) Return a new column group containing only the selected rows in the given boolean vector.ColGroupConst.removeEmptyRows(boolean[] selectV, int rOut) ColGroupDDC.removeEmptyRows(boolean[] selectV, int rOut) ColGroupDDCFOR.removeEmptyRows(boolean[] selectV, int rOut) ColGroupDDCLZW.removeEmptyRows(boolean[] selectV, int rOut) ColGroupEmpty.removeEmptyRows(boolean[] selectV, int rOut) ColGroupLinearFunctional.removeEmptyRows(boolean[] selectV, int rOut) ColGroupOLE.removeEmptyRows(boolean[] selectV, int rOut) ColGroupRLE.removeEmptyRows(boolean[] selectV, int rOut) ColGroupSDC.removeEmptyRows(boolean[] selectV, int rOut) ColGroupSDCFOR.removeEmptyRows(boolean[] selectV, int rOut) ColGroupSDCSingle.removeEmptyRows(boolean[] selectV, int rOut) ColGroupSDCSingleZeros.removeEmptyRows(boolean[] selectV, int rOut) ColGroupSDCZeros.removeEmptyRows(boolean[] selectV, int rOut) ColGroupUncompressed.removeEmptyRows(boolean[] selectV, int rOut) ColGroupUncompressedArray.removeEmptyRows(boolean[] selectV, int rOut) abstract AColGroupAColGroup.replace(double pattern, double replace) Make a copy of the column group values, and replace all values that match pattern with replacement value.AColGroupValue.replace(double pattern, double replace) ColGroupConst.replace(double pattern, double replace) ColGroupDDCFOR.replace(double pattern, double replace) ColGroupEmpty.replace(double pattern, double replace) ColGroupLinearFunctional.replace(double pattern, double replace) ColGroupSDC.replace(double pattern, double replace) ColGroupSDCFOR.replace(double pattern, double replace) ColGroupSDCSingle.replace(double pattern, double replace) ColGroupSDCSingleZeros.replace(double pattern, double replace) ColGroupSDCZeros.replace(double pattern, double replace) ColGroupUncompressed.replace(double pattern, double replace) ColGroupUncompressedArray.replace(double pattern, double replace) abstract AColGroupAColGroup.rexpandCols(int max, boolean ignore, boolean cast, int nRows) Expand the column group to multiple columns.AColGroupValue.rexpandCols(int max, boolean ignore, boolean cast, int nRows) ColGroupConst.rexpandCols(int max, boolean ignore, boolean cast, int nRows) ColGroupDDCFOR.rexpandCols(int max, boolean ignore, boolean cast, int nRows) ColGroupEmpty.rexpandCols(int max, boolean ignore, boolean cast, int nRows) ColGroupLinearFunctional.rexpandCols(int max, boolean ignore, boolean cast, int nRows) ColGroupSDC.rexpandCols(int max, boolean ignore, boolean cast, int nRows) ColGroupSDCFOR.rexpandCols(int max, boolean ignore, boolean cast, int nRows) ColGroupSDCSingle.rexpandCols(int max, boolean ignore, boolean cast, int nRows) ColGroupUncompressed.rexpandCols(int max, boolean ignore, boolean cast, int nRows) ColGroupUncompressedArray.rexpandCols(int max, boolean ignore, boolean cast, int nRows) final AColGroupAColGroup.rightMultByMatrix(MatrixBlock right) Right matrix multiplication with this column group.abstract AColGroupAColGroup.rightMultByMatrix(MatrixBlock right, IColIndex allCols, int k) Right matrix multiplication with this column group.final AColGroupADictBasedColGroup.rightMultByMatrix(MatrixBlock right, IColIndex allCols, int k) ColGroupEmpty.rightMultByMatrix(MatrixBlock right, IColIndex allCols, int k) ColGroupLinearFunctional.rightMultByMatrix(MatrixBlock right, IColIndex allCols, int k) ColGroupUncompressed.rightMultByMatrix(MatrixBlock right, IColIndex allCols, int k) ColGroupUncompressedArray.rightMultByMatrix(MatrixBlock right, IColIndex allCols, int k) abstract AColGroupAColGroup.scalarOperation(ScalarOperator op) Perform the specified scalar operation directly on the compressed column group, without decompressing individual cells if possible.ColGroupConst.scalarOperation(ScalarOperator op) ColGroupDDC.scalarOperation(ScalarOperator op) ColGroupDDCFOR.scalarOperation(ScalarOperator op) ColGroupDDCLZW.scalarOperation(ScalarOperator op) ColGroupDeltaDDC.scalarOperation(ScalarOperator op) ColGroupEmpty.scalarOperation(ScalarOperator op) ColGroupLinearFunctional.scalarOperation(ScalarOperator op) ColGroupOLE.scalarOperation(ScalarOperator op) ColGroupRLE.scalarOperation(ScalarOperator op) ColGroupSDC.scalarOperation(ScalarOperator op) ColGroupSDCFOR.scalarOperation(ScalarOperator op) ColGroupSDCSingle.scalarOperation(ScalarOperator op) ColGroupSDCSingleZeros.scalarOperation(ScalarOperator op) ColGroupSDCZeros.scalarOperation(ScalarOperator op) ColGroupUncompressed.scalarOperation(ScalarOperator op) ColGroupUncompressedArray.scalarOperation(ScalarOperator op) final AColGroupAColGroup.shiftColIndices(int offset) Shift all column indexes contained by an offset.final AColGroupAColGroup.sliceColumn(int col) Slice out a single column from the column group.final AColGroupAColGroup.sliceColumns(int cl, int cu) Slice out the columns within the range of cl and cu to remove the dictionary values related to these columns.abstract AColGroupAColGroup.sliceRows(int rl, int ru) Slice range of rows out of the column group and return a new column group only containing the row segment.ColGroupConst.sliceRows(int rl, int ru) ColGroupDDC.sliceRows(int rl, int ru) ColGroupDDCFOR.sliceRows(int rl, int ru) ColGroupDDCLZW.sliceRows(int rl, int ru) ColGroupDeltaDDC.sliceRows(int rl, int ru) ColGroupEmpty.sliceRows(int rl, int ru) ColGroupLinearFunctional.sliceRows(int rl, int ru) ColGroupOLE.sliceRows(int rl, int ru) ColGroupRLE.sliceRows(int rl, int ru) ColGroupSDC.sliceRows(int rl, int ru) ColGroupSDCFOR.sliceRows(int rl, int ru) ColGroupSDCSingle.sliceRows(int rl, int ru) ColGroupSDCSingleZeros.sliceRows(int rl, int ru) ColGroupSDCZeros.sliceRows(int rl, int ru) ColGroupUncompressed.sliceRows(int rl, int ru) ColGroupUncompressedArray.sliceRows(int rl, int ru) abstract AColGroupAColGroup.sort()Sort the values of the column group according to double comparison operations and return as another compressed group.ColGroupConst.sort()ColGroupDDC.sort()ColGroupDDCFOR.sort()ColGroupDDCLZW.sort()ColGroupEmpty.sort()ColGroupLinearFunctional.sort()ColGroupOLE.sort()ColGroupRLE.sort()ColGroupSDC.sort()ColGroupSDCFOR.sort()ColGroupSDCSingle.sort()ColGroupSDCSingleZeros.sort()ColGroupSDCZeros.sort()ColGroupUncompressed.sort()ColGroupUncompressedArray.sort()AColGroup.sortColumnIndexes()ColGroupDDC.sparsifyFOR()static AColGroupColGroupDDCFOR.sparsifyFOR(ColGroupDDC g) ColGroupSDC.sparsifyFOR()static AColGroupColGroupSDCFOR.sparsifyFOR(ColGroupSDC g) abstract AColGroup[]AColGroup.splitReshape(int multiplier, int nRow, int nColOrg) This method returns a list of column groups that are naive splits of this column group as if it is reshaped.ColGroupConst.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupDDC.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupDDCFOR.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupDDCLZW.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupEmpty.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupLinearFunctional.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupOLE.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupRLE.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupSDC.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupSDCFOR.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupSDCSingle.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupSDCSingleZeros.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupSDCZeros.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupUncompressed.splitReshape(int multiplier, int nRow, int nColOrg) ColGroupUncompressedArray.splitReshape(int multiplier, int nRow, int nColOrg) AColGroup.splitReshapePushDown(int multiplier, int nRow, int nColOrg, ExecutorService pool) This method returns a list of column groups that are naive splits of this column group as if it is reshaped.ColGroupDDC.splitReshapePushDown(int multiplier, int nRow, int nColOrg, ExecutorService pool) ColGroupSDC.subtractDefaultTuple()abstract AColGroupAColGroup.unaryOperation(UnaryOperator op) Perform unary operation on the column group and return a new column groupColGroupConst.unaryOperation(UnaryOperator op) ColGroupDDC.unaryOperation(UnaryOperator op) ColGroupDDCFOR.unaryOperation(UnaryOperator op) ColGroupDDCLZW.unaryOperation(UnaryOperator op) ColGroupDeltaDDC.unaryOperation(UnaryOperator op) ColGroupEmpty.unaryOperation(UnaryOperator op) ColGroupLinearFunctional.unaryOperation(UnaryOperator op) ColGroupOLE.unaryOperation(UnaryOperator op) ColGroupRLE.unaryOperation(UnaryOperator op) ColGroupSDC.unaryOperation(UnaryOperator op) ColGroupSDCFOR.unaryOperation(UnaryOperator op) ColGroupSDCSingle.unaryOperation(UnaryOperator op) ColGroupSDCSingleZeros.unaryOperation(UnaryOperator op) ColGroupSDCZeros.unaryOperation(UnaryOperator op) ColGroupUncompressed.unaryOperation(UnaryOperator op) ColGroupUncompressedArray.unaryOperation(UnaryOperator op) Methods in org.apache.sysds.runtime.compress.colgroup that return types with arguments of type AColGroupModifier and TypeMethodDescriptionColGroupFactory.compressColGroups(MatrixBlock in, CompressedSizeInfo csi, CompressionSettings cs) The actual compression method, that handles the logic of compressing multiple columns together.ColGroupFactory.compressColGroups(MatrixBlock in, CompressedSizeInfo csi, CompressionSettings cs, int k) The actual compression method, that handles the logic of compressing multiple columns together.ColGroupFactory.compressColGroups(MatrixBlock in, CompressedSizeInfo csi, CompressionSettings cs, ACostEstimate ce, int k) ColGroupIO.readGroups(DataInput in, int nRows) Read groups from a file.Methods in org.apache.sysds.runtime.compress.colgroup with parameters of type AColGroupModifier and TypeMethodDescriptionabstract AColGroupAppend the other column group to this column group.static AColGroupAppend all column groups in the list provided together in one go allocating the output once.ColGroupConst.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupDDC.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupDDCFOR.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupDeltaDDC.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupEmpty.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupLinearFunctional.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupOLE.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupRLE.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupSDC.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupSDCFOR.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupSDCSingle.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupSDCSingleZeros.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupSDCZeros.appendNInternal(AColGroup[] g, int blen, int rlen) ColGroupUncompressed.appendNInternal(AColGroup[] g, int blen, int rlen) Combine this column group with anotherAColGroup.combineWithSameIndex(int nRow, int nCol, AColGroup right) C bind the given column group to this.ColGroupConst.combineWithSameIndex(int nRow, int nCol, AColGroup right) ColGroupDDC.combineWithSameIndex(int nRow, int nCol, AColGroup right) ColGroupDDCFOR.combineWithSameIndex(int nRow, int nCol, AColGroup right) ColGroupEmpty.combineWithSameIndex(int nRow, int nCol, AColGroup right) ColGroupSDC.combineWithSameIndex(int nRow, int nCol, AColGroup right) ColGroupSDCFOR.combineWithSameIndex(int nRow, int nCol, AColGroup right) ColGroupSDCSingle.combineWithSameIndex(int nRow, int nCol, AColGroup right) ColGroupSDCSingleZeros.combineWithSameIndex(int nRow, int nCol, AColGroup right) ColGroupSDCZeros.combineWithSameIndex(int nRow, int nCol, AColGroup right) ColGroupUncompressed.combineWithSameIndex(int nRow, int nCol, AColGroup right) static voidColGroupUtils.copyValuesColGroupMatrixBlocks(AColGroup lhs, AColGroup rhs, MatrixBlock tmpResult, MatrixBlock result) Copy values from tmpResult into correct positions of result (according to colIndexes in lhs and rhs)abstract voidAColGroup.leftMultByAColGroup(AColGroup lhs, MatrixBlock result, int nRows) Left side matrix multiplication with a column group that is transposed.final voidAMorphingMMColGroup.leftMultByAColGroup(AColGroup lhs, MatrixBlock result, int nRows) final voidAPreAgg.leftMultByAColGroup(AColGroup lhs, MatrixBlock result, int nRows) voidColGroupConst.leftMultByAColGroup(AColGroup lhs, MatrixBlock result, int nRows) voidColGroupEmpty.leftMultByAColGroup(AColGroup lhs, MatrixBlock c, int nRows) voidColGroupLinearFunctional.leftMultByAColGroup(AColGroup lhs, MatrixBlock result, int nRows) voidColGroupUncompressed.leftMultByAColGroup(AColGroup lhs, MatrixBlock result, int nRows) voidColGroupUncompressedArray.leftMultByAColGroup(AColGroup lhs, MatrixBlock result, int nRows) booleanAColGroup.sameIndexStructure(AColGroup that) Method to determine if the columnGroup have the same index structure as another.booleanAColGroupCompressed.sameIndexStructure(AColGroup that) booleanColGroupUncompressed.sameIndexStructure(AColGroup that) abstract voidAColGroup.tsmmAColGroup(AColGroup other, MatrixBlock result) Matrix multiply with this other column group, but: 1.final voidAMorphingMMColGroup.tsmmAColGroup(AColGroup other, MatrixBlock result) final voidAPreAgg.tsmmAColGroup(AColGroup other, MatrixBlock result) voidColGroupConst.tsmmAColGroup(AColGroup other, MatrixBlock result) voidColGroupEmpty.tsmmAColGroup(AColGroup other, MatrixBlock result) voidColGroupLinearFunctional.tsmmAColGroup(AColGroup other, MatrixBlock result) voidColGroupUncompressed.tsmmAColGroup(AColGroup lhs, MatrixBlock result) voidColGroupUncompressedArray.tsmmAColGroup(AColGroup other, MatrixBlock result) Method parameters in org.apache.sysds.runtime.compress.colgroup with type arguments of type AColGroupModifier and TypeMethodDescriptionstatic double[]AColGroup.colSum(Collection<AColGroup> groups, double[] res, int nRows) Compute the column sum of the given list of groupsstatic double[]IContainDefaultTuple.combineDefaultTuples(double[] defTup, List<AColGroup> right) AColGroup.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) C bind the list of column groups with this column group.ColGroupConst.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) ColGroupDDC.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) ColGroupDDCFOR.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) ColGroupEmpty.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) ColGroupSDC.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) ColGroupSDCFOR.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) ColGroupSDCSingle.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) ColGroupSDCSingleZeros.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) ColGroupSDCZeros.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) ColGroupUncompressed.combineWithSameIndex(int nRow, int nCol, List<AColGroup> right) static longColGroupIO.getExactSizeOnDisk(List<AColGroup> colGroups) Get the size on disk for the given list of column groupsstatic voidColGroupIO.writeGroups(DataOutput out, Collection<AColGroup> colGroups) Writes the ColGroups out to the DataOutput. -
Uses of AColGroup in org.apache.sysds.runtime.compress.colgroup.indexes
Methods in org.apache.sysds.runtime.compress.colgroup.indexes with parameters of type AColGroupMethod parameters in org.apache.sysds.runtime.compress.colgroup.indexes with type arguments of type AColGroup -
Uses of AColGroup in org.apache.sysds.runtime.compress.colgroup.scheme
Methods in org.apache.sysds.runtime.compress.colgroup.scheme that return AColGroupModifier and TypeMethodDescriptionfinal AColGroupACLAScheme.encode(MatrixBlock data) final AColGroupACLAScheme.encode(MatrixBlock data, IColIndex columns) ICLAScheme.encode(MatrixBlock data) Encode the given matrix block into the scheme provided in the instance.ICLAScheme.encode(MatrixBlock data, IColIndex columns) Encode a given matrix block into the scheme provided in the instance but overwrite what columns to use.final AColGroupACLAScheme.encodeT(MatrixBlock data) final AColGroupACLAScheme.encodeT(MatrixBlock data, IColIndex columns) ICLAScheme.encodeT(MatrixBlock data) Encode the given matrix block into the scheme provided in the instance, the input data is transposed The method is unsafe in the sense that if the encoding scheme does not fit, there is no guarantee that an error is thrown.ICLAScheme.encodeT(MatrixBlock data, IColIndex columns) Encode a given matrix block into the scheme provided in the instance but overwrite what columns to use.Methods in org.apache.sysds.runtime.compress.colgroup.scheme that return types with arguments of type AColGroupModifier and TypeMethodDescriptionfinal Pair<ICLAScheme,AColGroup> ACLAScheme.updateAndEncode(MatrixBlock data) final Pair<ICLAScheme,AColGroup> ACLAScheme.updateAndEncode(MatrixBlock data, IColIndex columns) ICLAScheme.updateAndEncode(MatrixBlock data) Update and encode the given block in a single pass.ICLAScheme.updateAndEncode(MatrixBlock data, IColIndex columns) Try to update and encode in a single pass over the data.final Pair<ICLAScheme,AColGroup> ACLAScheme.updateAndEncodeT(MatrixBlock data) final Pair<ICLAScheme,AColGroup> ACLAScheme.updateAndEncodeT(MatrixBlock data, IColIndex columns) ICLAScheme.updateAndEncodeT(MatrixBlock data) Update and encode the given block in a single pass.ICLAScheme.updateAndEncodeT(MatrixBlock data, IColIndex columns) Try to update and encode in a single pass over the data. -
Uses of AColGroup in org.apache.sysds.runtime.compress.cost
Methods in org.apache.sysds.runtime.compress.cost with parameters of type AColGroupModifier and TypeMethodDescriptionabstract doubleGet the cost of a compressed columnGroup.doubledoubledoubledoubleMethod parameters in org.apache.sysds.runtime.compress.cost with type arguments of type AColGroupModifier and TypeMethodDescriptiondoubleACostEstimate.getCost(Collection<AColGroup> cgs, int nRows) Get the cost of a collection of column groups. -
Uses of AColGroup in org.apache.sysds.runtime.compress.lib
Fields in org.apache.sysds.runtime.compress.lib with type parameters of type AColGroupMethods in org.apache.sysds.runtime.compress.lib that return AColGroupModifier and TypeMethodDescriptionstatic AColGroupCombine the column groups A and B together.static AColGroupCLALibCombineGroups.combineN(List<AColGroup> groups, int nRows, ExecutorService pool, int k) static AColGroupCLALibCombineGroups.combineNMergeTree(List<AColGroup> groups, int nRows, ExecutorService pool, int k) static AColGroupCLALibCombineGroups.combineNSingleAtATime(List<AColGroup> groups, int nRows) Methods in org.apache.sysds.runtime.compress.lib that return types with arguments of type AColGroupModifier and TypeMethodDescriptionCLALibCombineGroups.combine(CompressedMatrixBlock cmb, CompressedSizeInfo csi, ExecutorService pool, int k) Combine a set of separated groups back together.CLALibCombineGroups.findGroupsInIndex(IColIndex idx, List<AColGroup> groups) Methods in org.apache.sysds.runtime.compress.lib with parameters of type AColGroupMethod parameters in org.apache.sysds.runtime.compress.lib with type arguments of type AColGroupModifier and TypeMethodDescriptionCombine a set of separated groups back together.static AColGroupCLALibCombineGroups.combineN(List<AColGroup> groups, int nRows, ExecutorService pool, int k) static AColGroupCLALibCombineGroups.combineNMergeTree(List<AColGroup> groups, int nRows, ExecutorService pool, int k) static AColGroupCLALibCombineGroups.combineNSingleAtATime(List<AColGroup> groups, int nRows) static voidCLALibDecompress.decompressDense(MatrixBlock ret, List<AColGroup> groups, double[] constV, double eps, int k, boolean overlapping) CLALibCombineGroups.findGroupsInIndex(IColIndex idx, List<AColGroup> groups) Split a given list of column groups into separate subparts.