Modifier and Type | Method and Description |
---|---|
void |
AbstractCompressedMatrixBlock.incrementalAggregate(AggregateOperator aggOp,
MatrixValue newWithCorrection) |
void |
AbstractCompressedMatrixBlock.incrementalAggregate(AggregateOperator aggOp,
MatrixValue correction,
MatrixValue newWithCorrection,
boolean deep) |
Modifier and Type | Method and Description |
---|---|
static void |
LibTensorAgg.aggregateBinaryTensor(BasicTensorBlock in,
BasicTensorBlock aggVal,
AggregateOperator aop)
Core incremental tensor aggregate (ak+) as used for uack+ and acrk+.
|
void |
BasicTensorBlock.incrementalAggregate(AggregateOperator aggOp,
BasicTensorBlock partialResult) |
Modifier and Type | Method and Description |
---|---|
static AggregateOperator |
InstructionUtils.parseAggregateOperator(String opcode,
String corrLoc) |
Modifier and Type | Method and Description |
---|---|
static AggregateOperator |
SpoofSPInstruction.getAggregateOperator(SpoofCellwise.AggOp aggop) |
Constructor and Description |
---|
AggregateDropCorrectionFunction(AggregateOperator op) |
Modifier and Type | Method and Description |
---|---|
static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> |
RDDAggregateUtils.aggByKeyStable(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> in,
AggregateOperator aop) |
static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> |
RDDAggregateUtils.aggByKeyStable(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> in,
AggregateOperator aop,
boolean deepCopyCombiner) |
static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> |
RDDAggregateUtils.aggByKeyStable(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> in,
AggregateOperator aop,
int numPartitions,
boolean deepCopyCombiner) |
static MatrixBlock |
RDDAggregateUtils.aggStable(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> in,
AggregateOperator aop)
Single block aggregation over pair rdds with corrections for numerical stability.
|
static MatrixBlock |
RDDAggregateUtils.aggStable(org.apache.spark.api.java.JavaRDD<MatrixBlock> in,
AggregateOperator aop)
Single block aggregation over rdds with corrections for numerical stability.
|
static TensorBlock |
RDDAggregateUtils.aggStableTensor(org.apache.spark.api.java.JavaPairRDD<TensorIndexes,TensorBlock> in,
AggregateOperator aop)
Single block aggregation over pair rdds with corrections for numerical stability.
|
static TensorBlock |
RDDAggregateUtils.aggStableTensor(org.apache.spark.api.java.JavaRDD<TensorBlock> in,
AggregateOperator aop)
Single block aggregation over rdds with corrections for numerical stability.
|
Modifier and Type | Method and Description |
---|---|
static void |
LibMatrixAgg.aggregateBinaryMatrix(MatrixBlock in,
MatrixBlock aggVal,
AggregateOperator aop)
Core incremental matrix aggregate (ak+) as used for uack+ and acrk+.
|
abstract void |
MatrixValue.incrementalAggregate(AggregateOperator aggOp,
MatrixValue newWithCorrection) |
void |
MatrixCell.incrementalAggregate(AggregateOperator aggOp,
MatrixValue newWithCorrection) |
void |
MatrixBlock.incrementalAggregate(AggregateOperator aggOp,
MatrixValue newWithCorrection) |
void |
CM_N_COVCell.incrementalAggregate(AggregateOperator aggOp,
MatrixValue newWithCorrection) |
abstract void |
MatrixValue.incrementalAggregate(AggregateOperator aggOp,
MatrixValue correction,
MatrixValue newWithCorrection,
boolean deep) |
void |
MatrixCell.incrementalAggregate(AggregateOperator aggOp,
MatrixValue correction,
MatrixValue newWithCorrection,
boolean deep) |
void |
MatrixBlock.incrementalAggregate(AggregateOperator aggOp,
MatrixValue correction,
MatrixValue newWithCorrection,
boolean deep) |
void |
CM_N_COVCell.incrementalAggregate(AggregateOperator aggOp,
MatrixValue correction,
MatrixValue newWithCorrection,
boolean deep) |
static void |
OperationsOnMatrixValues.incrementalAggregation(MatrixValue valueAgg,
MatrixValue correction,
MatrixValue valueAdd,
AggregateOperator op,
boolean embeddedCorrection) |
static void |
OperationsOnMatrixValues.incrementalAggregation(MatrixValue valueAgg,
MatrixValue correction,
MatrixValue valueAdd,
AggregateOperator op,
boolean embeddedCorrection,
boolean deep) |
static void |
OperationsOnMatrixValues.startAggregation(MatrixValue valueOut,
MatrixValue correction,
AggregateOperator op,
int rlen,
int clen,
boolean sparseHint,
boolean embeddedCorrection) |
Modifier and Type | Field and Description |
---|---|
AggregateOperator |
AggregateBinaryOperator.aggOp |
AggregateOperator |
AggregateUnaryOperator.aggOp |
AggregateOperator |
AggregateTernaryOperator.aggOp |
Constructor and Description |
---|
AggregateBinaryOperator(ValueFunction inner,
AggregateOperator outer) |
AggregateBinaryOperator(ValueFunction inner,
AggregateOperator outer,
int numThreads) |
AggregateTernaryOperator(ValueFunction inner,
AggregateOperator outer,
IndexFunction ixfun) |
AggregateTernaryOperator(ValueFunction inner,
AggregateOperator outer,
IndexFunction ixfun,
int numThreads) |
AggregateUnaryOperator(AggregateOperator aop,
IndexFunction iop) |
AggregateUnaryOperator(AggregateOperator aop,
IndexFunction iop,
int numThreads) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.