public class CompressedMatrixBlock extends AbstractCompressedMatrixBlock
MatrixBlock.SparsityEstimateMatrixValue.CellIndexCONVERT_MCSR_TO_CSR_ON_DEEP_SERIALIZE, DEFAULT_INPLACE_SPARSEBLOCK, DEFAULT_SPARSEBLOCK, HEADER_SIZE, MAX_SHALLOW_SERIALIZE_OVERHEAD, SPARSITY_TURN_POINT, ULTRA_SPARSE_BLOCK_NNZ, ULTRA_SPARSITY_TURN_POINT, ULTRA_SPARSITY_TURN_POINT2| Constructor and Description |
|---|
CompressedMatrixBlock()
Constructor for building an empty Compressed Matrix block object.
|
aggregateBinaryOperations, aggregateTernaryOperations, append, append, binaryOperations, binaryOperationsInPlace, cmOperations, cmOperations, covOperations, covOperations, ctableOperations, ctableOperations, ctableOperations, ctableOperations, ctableOperations, ctableOperations, ctableSeqOperations, estimateOriginalSizeInMemory, groupedAggOperations, groupedAggOperations, incrementalAggregate, incrementalAggregate, isEmptyBlock, isShallowSerialize, isShallowSerialize, leftIndexingOperations, leftIndexingOperations, permutationMatrixMultOperations, permutationMatrixMultOperations, quaternaryOperations, quaternaryOperations, randOperationsInPlace, randOperationsInPlace, removeEmptyOperations, removeEmptyOperations, reorgOperations, replaceOperations, rexpandOperations, seqOperationsInPlace, slice, slice, sortOperations, ternaryOperations, toShallowSerializeBlock, uaggouterchainOperations, unaryOperations, zeroOutOperationsallocateAndResetSparseBlock, allocateBlock, allocateBlockAsync, allocateDenseBlock, allocateDenseBlock, allocateDenseBlockUnsafe, allocateSparseRowsBlock, allocateSparseRowsBlock, append, appendRow, appendRow, appendRowToSparse, appendToSparse, appendToSparse, appendValue, checkNaN, checkNonZeros, checkSparseRows, checkSparseRows, cleanupBlock, compactEmptyBlock, compareTo, computeIQMCorrection, containsValue, copy, copy, copy, copyShallow, dropLastRowsOrColumns, equals, estimateSizeDenseInMemory, estimateSizeInMemory, estimateSizeInMemory, estimateSizeOnDisk, estimateSizeOnDisk, estimateSizeSparseInMemory, estimateSizeSparseInMemory, estimateSparsityOnAggBinary, evalSparseFormatInMemory, evalSparseFormatInMemory, evalSparseFormatInMemory, evalSparseFormatOnDisk, evalSparseFormatOnDisk, examSparsity, examSparsity, extractTriangular, getDataCharacteristics, getDenseBlock, getDenseBlockValues, getExactSerializedSize, getInMemorySize, getLength, getNonZeros, getNumColumns, getNumRows, getSparseBlock, getSparseBlockIterator, getSparseBlockIterator, getSparsity, getValue, getValueDenseUnsafe, hashCode, init, init, interQuartileMean, isAllocated, isEmpty, isEmptyBlock, isInSparseFormat, isSparsePermutationMatrix, isThreadSafe, isThreadSafe, isUltraSparse, isUltraSparse, isVector, leftIndexingOperations, max, mean, median, merge, merge, merge, merge, min, minNonZero, naryOperations, pickValue, pickValue, pickValues, prod, quickSetValue, randOperations, randOperations, randOperations, randOperations, recomputeNonZeros, recomputeNonZeros, recomputeNonZeros, reset, reset, reset, reset, reset, reset, sampleOperations, seqOperations, setNonZeros, setNumColumns, setNumRows, setSparseBlock, setValue, slice, slice, slice, sortSparseRows, sortSparseRows, sparseToDense, sum, sumSq, sumWeightForQuantilepublic CompressedMatrixBlock()
public boolean isSingleUncompressedGroup()
public MatrixBlock decompress()
decompress in class AbstractCompressedMatrixBlockpublic MatrixBlock decompress(int k)
k - degree of parallelismpublic long estimateCompressedSizeInMemory()
public static long baseSizeInMemory()
public double quickGetValue(int r,
int c)
quickGetValue in class MatrixBlockpublic long getExactSizeOnDisk()
MatrixBlockgetExactSizeOnDisk in class MatrixBlockpublic void readFields(DataInput in) throws IOException
readFields in interface org.apache.hadoop.io.WritablereadFields in class MatrixBlockIOExceptionpublic void write(DataOutput out) throws IOException
write in interface org.apache.hadoop.io.Writablewrite in class MatrixBlockIOExceptionpublic void readExternal(ObjectInput is) throws IOException
readExternal in interface ExternalizablereadExternal in class MatrixBlockis - object inputIOException - if IOException occurspublic void writeExternal(ObjectOutput os) throws IOException
writeExternal in interface ExternalizablewriteExternal in class MatrixBlockos - object outputIOException - if IOException occurspublic Iterator<double[]> getDenseRowIterator(int rl, int ru)
public int[] countNonZerosPerRow(int rl,
int ru)
public MatrixBlock scalarOperations(ScalarOperator sop, MatrixValue result)
scalarOperations in class MatrixBlockpublic MatrixBlock append(MatrixBlock that, MatrixBlock ret)
append in class MatrixBlockpublic MatrixBlock chainMatrixMultOperations(MatrixBlock v, MatrixBlock w, MatrixBlock out, MapMultChain.ChainType ctype)
chainMatrixMultOperations in class MatrixBlockpublic MatrixBlock chainMatrixMultOperations(MatrixBlock v, MatrixBlock w, MatrixBlock out, MapMultChain.ChainType ctype, int k)
chainMatrixMultOperations in class MatrixBlockpublic MatrixBlock aggregateBinaryOperations(MatrixBlock m1, MatrixBlock m2, MatrixBlock ret, AggregateBinaryOperator op)
aggregateBinaryOperations in class MatrixBlockpublic MatrixBlock aggregateUnaryOperations(AggregateUnaryOperator op, MatrixValue result, int blen, MatrixIndexes indexesIn, boolean inCP)
aggregateUnaryOperations in class MatrixBlockpublic MatrixBlock aggregateUnaryOperations(AggregateUnaryOperator op, MatrixValue result, int blen, MatrixIndexes indexesIn)
aggregateUnaryOperations in class MatrixBlockpublic MatrixBlock transposeSelfMatrixMultOperations(MatrixBlock out, MMTSJ.MMTSJType tstype)
transposeSelfMatrixMultOperations in class MatrixBlockpublic MatrixBlock transposeSelfMatrixMultOperations(MatrixBlock out, MMTSJ.MMTSJType tstype, int k)
transposeSelfMatrixMultOperations in class MatrixBlockpublic boolean hasUncompressedColGroup()
public String toString()
toString in class MatrixBlockCopyright © 2020 The Apache Software Foundation. All rights reserved.