Uses of Class
org.apache.sysds.runtime.matrix.operators.AggregateOperator
Packages that use AggregateOperator
Package
Description
-
Uses of AggregateOperator in org.apache.sysds.runtime.compress
Methods in org.apache.sysds.runtime.compress with parameters of type AggregateOperatorModifier and TypeMethodDescriptionvoidCompressedMatrixBlock.incrementalAggregate(AggregateOperator aggOp, MatrixValue newWithCorrection) voidCompressedMatrixBlock.incrementalAggregate(AggregateOperator aggOp, MatrixValue correction, MatrixValue newWithCorrection, boolean deep) -
Uses of AggregateOperator in org.apache.sysds.runtime.data
Methods in org.apache.sysds.runtime.data with parameters of type AggregateOperatorModifier and TypeMethodDescriptionstatic voidLibTensorAgg.aggregateBinaryTensor(BasicTensorBlock in, BasicTensorBlock aggVal, AggregateOperator aop) Core incremental tensor aggregate (ak+) as used for uack+ and acrk+.voidBasicTensorBlock.incrementalAggregate(AggregateOperator aggOp, BasicTensorBlock partialResult) -
Uses of AggregateOperator in org.apache.sysds.runtime.instructions
Methods in org.apache.sysds.runtime.instructions that return AggregateOperatorModifier and TypeMethodDescriptionstatic AggregateOperatorInstructionUtils.parseAggregateOperator(String opcode, String corrLoc) -
Uses of AggregateOperator in org.apache.sysds.runtime.instructions.spark
Methods in org.apache.sysds.runtime.instructions.spark that return AggregateOperatorModifier and TypeMethodDescriptionstatic AggregateOperatorSpoofSPInstruction.getAggregateOperator(SpoofCellwise.AggOp aggop) -
Uses of AggregateOperator in org.apache.sysds.runtime.instructions.spark.functions
Constructors in org.apache.sysds.runtime.instructions.spark.functions with parameters of type AggregateOperator -
Uses of AggregateOperator in org.apache.sysds.runtime.instructions.spark.utils
Methods in org.apache.sysds.runtime.instructions.spark.utils with parameters of type AggregateOperatorModifier and TypeMethodDescriptionstatic 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 MatrixBlockRDDAggregateUtils.aggStable(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes, MatrixBlock> in, AggregateOperator aop) Single block aggregation over pair rdds with corrections for numerical stability.static MatrixBlockRDDAggregateUtils.aggStable(org.apache.spark.api.java.JavaRDD<MatrixBlock> in, AggregateOperator aop) Single block aggregation over rdds with corrections for numerical stability.static TensorBlockRDDAggregateUtils.aggStableTensor(org.apache.spark.api.java.JavaPairRDD<TensorIndexes, TensorBlock> in, AggregateOperator aop) Single block aggregation over pair rdds with corrections for numerical stability.static TensorBlockRDDAggregateUtils.aggStableTensor(org.apache.spark.api.java.JavaRDD<TensorBlock> in, AggregateOperator aop) Single block aggregation over rdds with corrections for numerical stability. -
Uses of AggregateOperator in org.apache.sysds.runtime.matrix.data
Methods in org.apache.sysds.runtime.matrix.data with parameters of type AggregateOperatorModifier and TypeMethodDescriptionstatic voidLibMatrixAgg.aggregateBinaryMatrix(MatrixBlock in, MatrixBlock aggVal, AggregateOperator aop) Core incremental matrix aggregate (ak+) as used for uack+ and acrk+.voidMatrixBlock.incrementalAggregate(AggregateOperator aggOp, MatrixValue newWithCorrection) voidMatrixBlock.incrementalAggregate(AggregateOperator aggOp, MatrixValue correction, MatrixValue newWithCorrection, boolean deep) voidMatrixCell.incrementalAggregate(AggregateOperator aggOp, MatrixValue newWithCorrection) voidMatrixCell.incrementalAggregate(AggregateOperator aggOp, MatrixValue correction, MatrixValue newWithCorrection, boolean deep) abstract voidMatrixValue.incrementalAggregate(AggregateOperator aggOp, MatrixValue newWithCorrection) abstract voidMatrixValue.incrementalAggregate(AggregateOperator aggOp, MatrixValue correction, MatrixValue newWithCorrection, boolean deep) static voidOperationsOnMatrixValues.incrementalAggregation(MatrixValue valueAgg, MatrixValue correction, MatrixValue valueAdd, AggregateOperator op, boolean embeddedCorrection) static voidOperationsOnMatrixValues.incrementalAggregation(MatrixValue valueAgg, MatrixValue correction, MatrixValue valueAdd, AggregateOperator op, boolean embeddedCorrection, boolean deep) -
Uses of AggregateOperator in org.apache.sysds.runtime.matrix.operators
Fields in org.apache.sysds.runtime.matrix.operators declared as AggregateOperatorModifier and TypeFieldDescriptionfinal AggregateOperatorAggregateBinaryOperator.aggOpfinal AggregateOperatorAggregateTernaryOperator.aggOpfinal AggregateOperatorAggregateUnaryOperator.aggOpConstructors in org.apache.sysds.runtime.matrix.operators with parameters of type AggregateOperatorModifierConstructorDescriptionAggregateBinaryOperator(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, int numThreads) UnarySketchOperator(AggregateOperator aop, IndexFunction indexFunction, Types.Direction direction) UnarySketchOperator(AggregateOperator aop, IndexFunction indexFunction, Types.Direction direction, int numThreads)