public class CompressedMatrixBlock extends MatrixBlock
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.
|
CompressedMatrixBlock(CompressedMatrixBlock that) |
CompressedMatrixBlock(int rl,
int cl)
Main constructor for building a block from scratch.
|
| Modifier and Type | Method and Description |
|---|---|
MatrixBlock |
aggregateBinaryOperations(MatrixBlock m1,
MatrixBlock m2,
AggregateBinaryOperator op) |
MatrixBlock |
aggregateBinaryOperations(MatrixBlock m1,
MatrixBlock m2,
MatrixBlock ret,
AggregateBinaryOperator op) |
MatrixBlock |
aggregateBinaryOperations(MatrixBlock m1,
MatrixBlock m2,
MatrixBlock ret,
AggregateBinaryOperator op,
boolean transposeLeft,
boolean transposeRight) |
MatrixBlock |
aggregateTernaryOperations(MatrixBlock m1,
MatrixBlock m2,
MatrixBlock m3,
MatrixBlock ret,
AggregateTernaryOperator op,
boolean inCP) |
MatrixBlock |
aggregateUnaryOperations(AggregateUnaryOperator op,
MatrixValue result,
int blen,
MatrixIndexes indexesIn,
boolean inCP) |
void |
allocateColGroup(AColGroup cg)
Allocate the given column group and remove all references to old column groups.
|
void |
allocateColGroupList(List<AColGroup> colGroups) |
MatrixBlock |
append(MatrixBlock that,
MatrixBlock ret) |
MatrixBlock |
append(MatrixBlock that,
MatrixBlock ret,
boolean cbind) |
void |
append(MatrixValue v2,
ArrayList<IndexedMatrixValue> outlist,
int blen,
boolean cbind,
boolean m2IsLast,
int nextNCol) |
static long |
baseSizeInMemory() |
MatrixBlock |
binaryOperations(BinaryOperator op,
MatrixValue thatValue,
MatrixValue result) |
MatrixBlock |
binaryOperationsInPlace(BinaryOperator op,
MatrixValue thatValue) |
MatrixBlock |
binaryOperationsLeft(BinaryOperator op,
MatrixValue thatValue,
MatrixValue result) |
MatrixBlock |
chainMatrixMultOperations(MatrixBlock v,
MatrixBlock w,
MatrixBlock out,
MapMultChain.ChainType ctype) |
MatrixBlock |
chainMatrixMultOperations(MatrixBlock v,
MatrixBlock w,
MatrixBlock out,
MapMultChain.ChainType ctype,
int k) |
void |
clearSoftReferenceToDecompressed() |
CM_COV_Object |
cmOperations(CMOperator op) |
CM_COV_Object |
cmOperations(CMOperator op,
MatrixBlock weights) |
boolean |
containsValue(double pattern) |
void |
copy(MatrixValue thatValue)
Copy that MatrixValue into this MatrixValue.
|
void |
copy(MatrixValue thatValue,
boolean sp)
Copy that MatrixValue into this MatrixValue.
|
CM_COV_Object |
covOperations(COVOperator op,
MatrixBlock that) |
CM_COV_Object |
covOperations(COVOperator op,
MatrixBlock that,
MatrixBlock weights) |
void |
ctableOperations(Operator op,
double scalar,
double scalar2,
CTableMap resultMap,
MatrixBlock resultBlock)
D = ctable(A,v2,w)
this <- A; scalar_that <- v2; scalar_that2 <- w; result <- D
(i1,j1,v1) from input1 (this)
(v2) from sclar_input2 (scalarThat)
(w) from scalar_input3 (scalarThat2)
|
void |
ctableOperations(Operator op,
double scalar,
MatrixValue that,
CTableMap resultMap,
MatrixBlock resultBlock)
D = ctable(A,v2,W)
this <- A; scalarThat <- v2; that2 <- W; result <- D
(i1,j1,v1) from input1 (this)
(v2) from sclar_input2 (scalarThat)
(i3,j3,w) from input3 (that2)
|
void |
ctableOperations(Operator op,
MatrixIndexes ix1,
double scalar,
boolean left,
int brlen,
CTableMap resultMap,
MatrixBlock resultBlock)
Specific ctable case of ctable(seq(...),X), where X is the only
matrix input.
|
void |
ctableOperations(Operator op,
MatrixValue that,
double scalar,
boolean ignoreZeros,
CTableMap resultMap,
MatrixBlock resultBlock)
D = ctable(A,B,w)
this <- A; that <- B; scalar_that2 <- w; result <- D
(i1,j1,v1) from input1 (this)
(i1,j1,v2) from input2 (that)
(w) from scalar_input3 (scalarThat2)
NOTE: This method supports both vectors and matrices.
|
void |
ctableOperations(Operator op,
MatrixValue that,
MatrixValue that2,
CTableMap resultMap)
D = ctable(A,B,W)
this <- A; that <- B; that2 <- W; result <- D
(i1,j1,v1) from input1 (this)
(i1,j1,v2) from input2 (that)
(i1,j1,w) from input3 (that2)
|
void |
ctableOperations(Operator op,
MatrixValue that,
MatrixValue that2,
CTableMap resultMap,
MatrixBlock resultBlock) |
MatrixBlock |
ctableSeqOperations(MatrixValue that,
double scalar,
MatrixBlock resultBlock)
D = ctable(seq,A,w)
this <- seq; thatMatrix <- A; thatScalar <- w; result <- D
(i1,j1,v1) from input1 (this)
(i1,j1,v2) from input2 (that)
(w) from scalar_input3 (scalarThat2)
|
MatrixBlock |
decompress()
Decompress block.
|
MatrixBlock |
decompress(int k)
Decompress block.
|
MatrixBlock |
decompress(MatrixBlock ret,
int k) |
long |
estimateCompressedSizeInMemory()
Obtain an upper bound on the memory used to store the compressed block.
|
List<AColGroup> |
getColGroups() |
long |
getExactSizeOnDisk()
NOTE: The used estimates must be kept consistent with the respective write functions.
|
org.apache.commons.lang3.tuple.Pair<Integer,int[]> |
getMaxNumValues() |
SoftReference<MatrixBlock> |
getSoftReferenceToDecompressed() |
MatrixBlock |
getUncompressed() |
static MatrixBlock |
getUncompressed(MatrixValue mVal) |
ColGroupUncompressed |
getUncompressedColGroup() |
MatrixBlock |
groupedAggOperations(MatrixValue tgt,
MatrixValue wghts,
MatrixValue ret,
int ngroups,
Operator op)
Invocation from CP instructions.
|
MatrixBlock |
groupedAggOperations(MatrixValue tgt,
MatrixValue wghts,
MatrixValue ret,
int ngroups,
Operator op,
int k) |
void |
incrementalAggregate(AggregateOperator aggOp,
MatrixValue newWithCorrection) |
void |
incrementalAggregate(AggregateOperator aggOp,
MatrixValue correction,
MatrixValue newWithCorrection,
boolean deep) |
boolean |
isEmptyBlock(boolean safe) |
boolean |
isOverlapping() |
boolean |
isShallowSerialize()
Indicates if the cache block is subject to shallow serialized,
which is generally true if in-memory size and serialized size
are almost identical allowing to avoid unnecessary deep serialize.
|
boolean |
isShallowSerialize(boolean inclConvert)
Indicates if the cache block is subject to shallow serialized,
which is generally true if in-memory size and serialized size
are almost identical allowing to avoid unnecessary deep serialize.
|
boolean |
isSingleUncompressedGroup() |
MatrixBlock |
leftIndexingOperations(MatrixBlock rhsMatrix,
int rl,
int ru,
int cl,
int cu,
MatrixBlock ret,
MatrixObject.UpdateType update) |
MatrixBlock |
leftIndexingOperations(ScalarObject scalar,
int rl,
int cl,
MatrixBlock ret,
MatrixObject.UpdateType update)
Explicitly allow left indexing for scalars.
|
double |
max()
Wrapper method for reduceall-max of a matrix.
|
double |
min()
Wrapper method for reduceall-min of a matrix.
|
void |
permutationMatrixMultOperations(MatrixValue m2Val,
MatrixValue out1Val,
MatrixValue out2Val) |
void |
permutationMatrixMultOperations(MatrixValue m2Val,
MatrixValue out1Val,
MatrixValue out2Val,
int k) |
MatrixBlock |
quaternaryOperations(QuaternaryOperator qop,
MatrixBlock um,
MatrixBlock vm,
MatrixBlock wm,
MatrixBlock out) |
MatrixBlock |
quaternaryOperations(QuaternaryOperator qop,
MatrixBlock um,
MatrixBlock vm,
MatrixBlock wm,
MatrixBlock out,
int k) |
double |
quickGetValue(int r,
int c) |
MatrixBlock |
randOperationsInPlace(RandomMatrixGenerator rgen,
org.apache.commons.math3.random.Well1024a bigrand,
long bSeed)
Function to generate a matrix of random numbers.
|
MatrixBlock |
randOperationsInPlace(RandomMatrixGenerator rgen,
org.apache.commons.math3.random.Well1024a bigrand,
long bSeed,
int k)
Function to generate a matrix of random numbers.
|
void |
readExternal(ObjectInput is)
Redirects the default java serialization via externalizable to our default hadoop writable serialization for
efficient broadcast/rdd de-serialization.
|
void |
readFields(DataInput in) |
long |
recomputeNonZeros()
Recomputes and materializes the number of non-zero values
of the entire matrix block.
|
MatrixBlock |
removeEmptyOperations(MatrixBlock ret,
boolean rows,
boolean emptyReturn) |
MatrixBlock |
removeEmptyOperations(MatrixBlock ret,
boolean rows,
boolean emptyReturn,
MatrixBlock select) |
MatrixBlock |
reorgOperations(ReorgOperator op,
MatrixValue ret,
int startRow,
int startColumn,
int length) |
MatrixBlock |
replaceOperations(MatrixValue result,
double pattern,
double replacement) |
MatrixBlock |
rexpandOperations(MatrixBlock ret,
double max,
boolean rows,
boolean cast,
boolean ignore,
int k) |
MatrixBlock |
scalarOperations(ScalarOperator sop,
MatrixValue result) |
MatrixBlock |
seqOperationsInPlace(double from,
double to,
double incr) |
void |
setOverlapping(boolean overlapping) |
void |
slice(ArrayList<IndexedMatrixValue> outlist,
IndexRange range,
int rowCut,
int colCut,
int blen,
int boundaryRlen,
int boundaryClen)
Slice out up to 4 matrixBlocks that are separated by the row and col Cuts.
|
MatrixBlock |
slice(int rl,
int ru,
int cl,
int cu,
boolean deep,
CacheBlock ret)
Method to perform rightIndex operation for a given lower and upper bounds in row and column dimensions.
|
MatrixBlock |
sortOperations(MatrixValue weights,
MatrixBlock result) |
CompressedMatrixBlock |
squash(int k) |
double |
sum()
Wrapper method for reduceall-sum of a matrix.
|
double |
sumSq()
Wrapper method for reduceall-sumSq of a matrix.
|
MatrixBlock |
ternaryOperations(TernaryOperator op,
MatrixBlock m2,
MatrixBlock m3,
MatrixBlock ret) |
void |
toShallowSerializeBlock()
Converts a cache block that is not shallow serializable into
a form that is shallow serializable.
|
String |
toString() |
MatrixBlock |
transposeSelfMatrixMultOperations(MatrixBlock out,
MMTSJ.MMTSJType tstype) |
MatrixBlock |
transposeSelfMatrixMultOperations(MatrixBlock out,
MMTSJ.MMTSJType tstype,
int k) |
MatrixBlock |
uaggouterchainOperations(MatrixBlock mbLeft,
MatrixBlock mbRight,
MatrixBlock mbOut,
BinaryOperator bOp,
AggregateUnaryOperator uaggOp) |
MatrixBlock |
unaryOperations(UnaryOperator op,
MatrixValue result) |
void |
write(DataOutput out) |
void |
writeExternal(ObjectOutput os)
Redirects the default java serialization via externalizable to our default hadoop writable serialization for
efficient broadcast/rdd serialization.
|
MatrixBlock |
zeroOutOperations(MatrixValue result,
IndexRange range,
boolean complementary) |
aggregateUnaryOperations, allocateAndResetSparseBlock, allocateBlock, allocateBlockAsync, allocateDenseBlock, allocateDenseBlock, allocateDenseBlockUnsafe, allocateSparseRowsBlock, allocateSparseRowsBlock, append, appendRow, appendRow, appendRowToSparse, appendToSparse, appendToSparse, appendValue, appendValuePlain, checkNaN, checkNonZeros, checkSparseRows, checkSparseRows, cleanupBlock, compactEmptyBlock, compareTo, computeIQMCorrection, copy, copyShallow, ctableSeqOperations, dropLastRowsOrColumns, equals, estimateSizeDenseInMemory, estimateSizeInMemory, estimateSizeInMemory, estimateSizeOnDisk, estimateSizeOnDisk, estimateSizeSparseInMemory, estimateSizeSparseInMemory, estimateSparsityOnAggBinary, evalSparseFormatInMemory, evalSparseFormatInMemory, evalSparseFormatInMemory, evalSparseFormatOnDisk, evalSparseFormatOnDisk, examSparsity, examSparsity, extractTriangular, getDataCharacteristics, getDenseBlock, getDenseBlockValues, getExactSerializedSize, getHeaderSize, 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, mean, median, merge, merge, merge, merge, minNonZero, naryOperations, pickValue, pickValue, pickValues, prepareAggregateUnaryOutput, prod, quickGetValueThreadSafe, quickSetValue, quickSetValueThreadSafe, randOperations, randOperations, randOperations, randOperations, recomputeNonZeros, recomputeNonZeros, reset, reset, reset, reset, reset, reset, sampleOperations, seqOperations, setDenseBlock, setNonZeros, setNumColumns, setNumRows, setSparseBlock, setValue, slice, slice, slice, slice, slice, slice, sortSparseRows, sortSparseRows, sparseToDense, sumWeightForQuantilepublic CompressedMatrixBlock()
public CompressedMatrixBlock(int rl,
int cl)
rl - number of rows in the blockcl - number of columnspublic CompressedMatrixBlock(CompressedMatrixBlock that)
public boolean isSingleUncompressedGroup()
public void allocateColGroup(AColGroup cg)
cg - The column group to use after.public MatrixBlock decompress()
public MatrixBlock decompress(int k)
k - degree of parallelismpublic MatrixBlock decompress(MatrixBlock ret, int k)
public CompressedMatrixBlock squash(int k)
public long recomputeNonZeros()
MatrixBlockrecomputeNonZeros in class MatrixBlockpublic 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 MatrixBlock scalarOperations(ScalarOperator sop, MatrixValue result)
scalarOperations in class MatrixBlockpublic MatrixBlock binaryOperations(BinaryOperator op, MatrixValue thatValue, MatrixValue result)
binaryOperations in class MatrixBlockpublic MatrixBlock binaryOperationsLeft(BinaryOperator op, MatrixValue thatValue, MatrixValue result)
public MatrixBlock append(MatrixBlock that, MatrixBlock ret)
append in class MatrixBlockpublic MatrixBlock append(MatrixBlock that, MatrixBlock ret, boolean cbind)
append in class MatrixBlockpublic void append(MatrixValue v2, ArrayList<IndexedMatrixValue> outlist, int blen, boolean cbind, boolean m2IsLast, int nextNCol)
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, AggregateBinaryOperator op)
aggregateBinaryOperations in class MatrixBlockpublic MatrixBlock aggregateBinaryOperations(MatrixBlock m1, MatrixBlock m2, MatrixBlock ret, AggregateBinaryOperator op)
aggregateBinaryOperations in class MatrixBlockpublic MatrixBlock aggregateBinaryOperations(MatrixBlock m1, MatrixBlock m2, MatrixBlock ret, AggregateBinaryOperator op, boolean transposeLeft, boolean transposeRight)
public MatrixBlock aggregateUnaryOperations(AggregateUnaryOperator op, MatrixValue result, int blen, MatrixIndexes indexesIn, boolean inCP)
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 MatrixBlock replaceOperations(MatrixValue result, double pattern, double replacement)
replaceOperations in class MatrixBlockpublic MatrixBlock reorgOperations(ReorgOperator op, MatrixValue ret, int startRow, int startColumn, int length)
reorgOperations in class MatrixBlockpublic ColGroupUncompressed getUncompressedColGroup()
public org.apache.commons.lang3.tuple.Pair<Integer,int[]> getMaxNumValues()
public String toString()
toString in class MatrixBlockpublic boolean isOverlapping()
public void setOverlapping(boolean overlapping)
public MatrixBlock slice(int rl, int ru, int cl, int cu, boolean deep, CacheBlock ret)
MatrixBlockslice in interface CacheBlockslice in class MatrixBlockrl - row lower if this value is bellow 0 or above the number of rows contained in the matrix an execption is thrownru - row upper if this value is bellow rl or above the number of rows contained in the matrix an exception is throwncl - column lower if this value us bellow 0 or above the number of columns contained in the matrix an exception is throwncu - column upper if this value us bellow cl or above the number of columns contained in the matrix an exception is throwndeep - should perform deep copy, this is relelvant in cases where the matrix is in sparse format,
or the entire matrix is sliced outret - output sliced out matrix blockpublic void slice(ArrayList<IndexedMatrixValue> outlist, IndexRange range, int rowCut, int colCut, int blen, int boundaryRlen, int boundaryClen)
MatrixValueslice in class MatrixBlockoutlist - The output matrix blocks that is extracted from the matrixrange - An index range containing overlapping information.rowCut - The row to cut and split the matrix.colCut - The column to cut ans split the matrix.blen - The Block size of the output matrices.boundaryRlen - The row length of the edge case matrix block, used for the final blocks
that does not have enough rows to construct a full block.boundaryClen - The col length of the edge case matrix block, used for the final blocks
that does not have enough cols to construct a full block.public MatrixBlock unaryOperations(UnaryOperator op, MatrixValue result)
unaryOperations in class MatrixBlockpublic boolean containsValue(double pattern)
containsValue in class MatrixBlockpublic double max()
MatrixBlockmax in class MatrixBlockpublic double min()
MatrixBlockmin in class MatrixBlockpublic double sum()
MatrixBlocksum in class MatrixBlockpublic double sumSq()
MatrixBlocksumSq in class MatrixBlockpublic MatrixBlock rexpandOperations(MatrixBlock ret, double max, boolean rows, boolean cast, boolean ignore, int k)
rexpandOperations in class MatrixBlockpublic boolean isEmptyBlock(boolean safe)
isEmptyBlock in class MatrixBlockpublic MatrixBlock binaryOperationsInPlace(BinaryOperator op, MatrixValue thatValue)
binaryOperationsInPlace in class MatrixBlockpublic void incrementalAggregate(AggregateOperator aggOp, MatrixValue correction, MatrixValue newWithCorrection, boolean deep)
incrementalAggregate in class MatrixBlockpublic void incrementalAggregate(AggregateOperator aggOp, MatrixValue newWithCorrection)
incrementalAggregate in class MatrixBlockpublic void permutationMatrixMultOperations(MatrixValue m2Val, MatrixValue out1Val, MatrixValue out2Val)
permutationMatrixMultOperations in class MatrixBlockpublic void permutationMatrixMultOperations(MatrixValue m2Val, MatrixValue out1Val, MatrixValue out2Val, int k)
permutationMatrixMultOperations in class MatrixBlockpublic MatrixBlock leftIndexingOperations(MatrixBlock rhsMatrix, int rl, int ru, int cl, int cu, MatrixBlock ret, MatrixObject.UpdateType update)
leftIndexingOperations in class MatrixBlockpublic MatrixBlock leftIndexingOperations(ScalarObject scalar, int rl, int cl, MatrixBlock ret, MatrixObject.UpdateType update)
MatrixBlockleftIndexingOperations in class MatrixBlockscalar - scalar objectrl - row lowercl - column lowerret - ?update - ?public MatrixBlock zeroOutOperations(MatrixValue result, IndexRange range, boolean complementary)
zeroOutOperations in class MatrixBlockpublic CM_COV_Object cmOperations(CMOperator op)
cmOperations in class MatrixBlockpublic CM_COV_Object cmOperations(CMOperator op, MatrixBlock weights)
cmOperations in class MatrixBlockpublic CM_COV_Object covOperations(COVOperator op, MatrixBlock that)
covOperations in class MatrixBlockpublic CM_COV_Object covOperations(COVOperator op, MatrixBlock that, MatrixBlock weights)
covOperations in class MatrixBlockpublic MatrixBlock sortOperations(MatrixValue weights, MatrixBlock result)
sortOperations in class MatrixBlockpublic MatrixBlock aggregateTernaryOperations(MatrixBlock m1, MatrixBlock m2, MatrixBlock m3, MatrixBlock ret, AggregateTernaryOperator op, boolean inCP)
aggregateTernaryOperations in class MatrixBlockpublic MatrixBlock uaggouterchainOperations(MatrixBlock mbLeft, MatrixBlock mbRight, MatrixBlock mbOut, BinaryOperator bOp, AggregateUnaryOperator uaggOp)
uaggouterchainOperations in class MatrixBlockpublic MatrixBlock groupedAggOperations(MatrixValue tgt, MatrixValue wghts, MatrixValue ret, int ngroups, Operator op)
MatrixBlockgroupedAggOperations in class MatrixBlocktgt - ?wghts - ?ret - ?ngroups - ?op - operatorpublic MatrixBlock groupedAggOperations(MatrixValue tgt, MatrixValue wghts, MatrixValue ret, int ngroups, Operator op, int k)
groupedAggOperations in class MatrixBlockpublic MatrixBlock removeEmptyOperations(MatrixBlock ret, boolean rows, boolean emptyReturn, MatrixBlock select)
removeEmptyOperations in class MatrixBlockpublic MatrixBlock removeEmptyOperations(MatrixBlock ret, boolean rows, boolean emptyReturn)
removeEmptyOperations in class MatrixBlockpublic void ctableOperations(Operator op, double scalar, MatrixValue that, CTableMap resultMap, MatrixBlock resultBlock)
MatrixBlockctableOperations in class MatrixBlockpublic void ctableOperations(Operator op, double scalar, double scalar2, CTableMap resultMap, MatrixBlock resultBlock)
MatrixBlockctableOperations in class MatrixBlockpublic void ctableOperations(Operator op, MatrixIndexes ix1, double scalar, boolean left, int brlen, CTableMap resultMap, MatrixBlock resultBlock)
MatrixBlockctableOperations in class MatrixBlockpublic void ctableOperations(Operator op, MatrixValue that, double scalar, boolean ignoreZeros, CTableMap resultMap, MatrixBlock resultBlock)
MatrixBlockctableOperations in class MatrixBlockpublic MatrixBlock ctableSeqOperations(MatrixValue that, double scalar, MatrixBlock resultBlock)
MatrixBlockctableSeqOperations in class MatrixBlockthat - matrix valuescalar - scalar doubleresultBlock - result matrix blockpublic void ctableOperations(Operator op, MatrixValue that, MatrixValue that2, CTableMap resultMap)
MatrixBlockctableOperations in class MatrixBlockop - operatorthat - matrix value 1that2 - matrix value 2resultMap - table mappublic void ctableOperations(Operator op, MatrixValue that, MatrixValue that2, CTableMap resultMap, MatrixBlock resultBlock)
ctableOperations in class MatrixBlockpublic MatrixBlock ternaryOperations(TernaryOperator op, MatrixBlock m2, MatrixBlock m3, MatrixBlock ret)
ternaryOperations in class MatrixBlockpublic MatrixBlock quaternaryOperations(QuaternaryOperator qop, MatrixBlock um, MatrixBlock vm, MatrixBlock wm, MatrixBlock out)
quaternaryOperations in class MatrixBlockpublic MatrixBlock quaternaryOperations(QuaternaryOperator qop, MatrixBlock um, MatrixBlock vm, MatrixBlock wm, MatrixBlock out, int k)
quaternaryOperations in class MatrixBlockpublic MatrixBlock randOperationsInPlace(RandomMatrixGenerator rgen, org.apache.commons.math3.random.Well1024a bigrand, long bSeed)
MatrixBlockbigrand is passed so that block-level
seeds are generated internally. In case of MR, it generates a single
block for given block-level seed bSeed.
When pdf="uniform", cell values are drawn from uniform distribution in
range [min,max].
When pdf="normal", cell values are drawn from standard normal
distribution N(0,1). The range of generated values will always be
(-Inf,+Inf).randOperationsInPlace in class MatrixBlockrgen - random matrix generatorbigrand - ?bSeed - seed valuepublic MatrixBlock randOperationsInPlace(RandomMatrixGenerator rgen, org.apache.commons.math3.random.Well1024a bigrand, long bSeed, int k)
MatrixBlockbigrand is passed so that block-level
seeds are generated internally. In case of MR, it generates a single
block for given block-level seed bSeed.
When pdf="uniform", cell values are drawn from uniform distribution in
range [min,max].
When pdf="normal", cell values are drawn from standard normal
distribution N(0,1). The range of generated values will always be
(-Inf,+Inf).randOperationsInPlace in class MatrixBlockrgen - random matrix generatorbigrand - ?bSeed - seed valuek - ?public MatrixBlock seqOperationsInPlace(double from, double to, double incr)
seqOperationsInPlace in class MatrixBlockpublic static MatrixBlock getUncompressed(MatrixValue mVal)
public MatrixBlock getUncompressed()
public boolean isShallowSerialize()
CacheBlockisShallowSerialize in interface CacheBlockisShallowSerialize in class MatrixBlockpublic boolean isShallowSerialize(boolean inclConvert)
CacheBlockisShallowSerialize in interface CacheBlockisShallowSerialize in class MatrixBlockinclConvert - if true report blocks as shallow serialize that are
currently not amenable but can be brought into an amenable form
via toShallowSerializeBlock.public void toShallowSerializeBlock()
CacheBlocktoShallowSerializeBlock in interface CacheBlocktoShallowSerializeBlock in class MatrixBlockpublic void copy(MatrixValue thatValue)
MatrixValuecopy in class MatrixBlockthatValue - object to copy the values into.public void copy(MatrixValue thatValue, boolean sp)
MatrixValuecopy in class MatrixBlockthatValue - object to copy the values into.sp - boolean specifying if output should be forced sparse or dense. (only applicable if the 'that' is a MatrixBlock)public SoftReference<MatrixBlock> getSoftReferenceToDecompressed()
public void clearSoftReferenceToDecompressed()
Copyright © 2021 The Apache Software Foundation. All rights reserved.