| 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.