org.apache.sysml.runtime.codegen

Class SpoofMultiAggregate

java.lang.Object

org.apache.sysml.runtime.codegen.SpoofOperator

org.apache.sysml.runtime.codegen.SpoofMultiAggregate

All Implemented Interfaces:

Serializable

public abstract class SpoofMultiAggregate
extends SpoofOperator
implements Serializable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.sysml.runtime.codegen.SpoofOperator

SpoofOperator.SideInput, SpoofOperator.SideInputSparseCell, SpoofOperator.SideInputSparseRow

Field Summary

Fields inherited from class org.apache.sysml.runtime.codegen.SpoofOperator

PAR_MINFLOP_THRESHOLD, PAR_NUMCELL_THRESHOLD

Constructor Summary

Constructors

Constructor and Description
SpoofMultiAggregate(boolean sparseSafe, SpoofCellwise.AggOp... aggOps)

Method Summary

Modifier and Type	Method and Description
static void	aggregatePartialResults(SpoofCellwise.AggOp[] aggOps, MatrixBlock c, MatrixBlock b)
MatrixBlock	execute(ArrayList<MatrixBlock> inputs, ArrayList<org.apache.sysml.runtime.instructions.cp.ScalarObject> scalarObjects, MatrixBlock out)
MatrixBlock	execute(ArrayList<MatrixBlock> inputs, ArrayList<org.apache.sysml.runtime.instructions.cp.ScalarObject> scalarObjects, MatrixBlock out, int k)
MatrixBlock	execute(ArrayList<MatrixBlock> inputs, ArrayList<org.apache.sysml.runtime.instructions.cp.ScalarObject> scalarObjects, MatrixBlock out, int k, long rix)
protected void	genexec(double a, SpoofOperator.SideInput[] b, double[] scalars, double[] c, int m, int n, int rix, int cix)
protected abstract void	genexec(double a, SpoofOperator.SideInput[] b, double[] scalars, double[] c, int m, int n, long grix, int rix, int cix)
static org.apache.sysml.runtime.functionobjects.ValueFunction[]	getAggFunctions(SpoofCellwise.AggOp[] aggOps)
SpoofCellwise.AggOp[]	getAggOps()
static double	getInitialValue(SpoofCellwise.AggOp aggop)
String	getSpoofType()
boolean	isSparseSafe()

Methods inherited from class org.apache.sysml.runtime.codegen.SpoofOperator

createSparseSideInputs, createSparseSideInputs, execute, execute, getDenseMatrices, getTotalInputNnz, getTotalInputSize, getValue, getValue, getValue, getValue, getValue, getValue, getValue, getValue, getValue, getValue, getVector, getVector, prepInputMatrices, prepInputMatrices, prepInputMatrices, prepInputMatrices, prepInputMatrices, prepInputScalars

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SpoofMultiAggregate

public SpoofMultiAggregate(boolean sparseSafe,
                           SpoofCellwise.AggOp... aggOps)

Method Detail

getAggOps

public SpoofCellwise.AggOp[] getAggOps()

isSparseSafe

public boolean isSparseSafe()

getSpoofType

public String getSpoofType()

Specified by:

getSpoofType in class SpoofOperator

execute

public MatrixBlock execute(ArrayList<MatrixBlock> inputs,
                           ArrayList<org.apache.sysml.runtime.instructions.cp.ScalarObject> scalarObjects,
                           MatrixBlock out)

Specified by:

execute in class SpoofOperator

execute

public MatrixBlock execute(ArrayList<MatrixBlock> inputs,
                           ArrayList<org.apache.sysml.runtime.instructions.cp.ScalarObject> scalarObjects,
                           MatrixBlock out,
                           int k)

Overrides:

execute in class SpoofOperator

execute

public MatrixBlock execute(ArrayList<MatrixBlock> inputs,
                           ArrayList<org.apache.sysml.runtime.instructions.cp.ScalarObject> scalarObjects,
                           MatrixBlock out,
                           int k,
                           long rix)

genexec

protected final void genexec(double a,
                             SpoofOperator.SideInput[] b,
                             double[] scalars,
                             double[] c,
                             int m,
                             int n,
                             int rix,
                             int cix)

genexec

protected abstract void genexec(double a,
                                SpoofOperator.SideInput[] b,
                                double[] scalars,
                                double[] c,
                                int m,
                                int n,
                                long grix,
                                int rix,
                                int cix)

getInitialValue

public static double getInitialValue(SpoofCellwise.AggOp aggop)

aggregatePartialResults

public static void aggregatePartialResults(SpoofCellwise.AggOp[] aggOps,
                                           MatrixBlock c,
                                           MatrixBlock b)

getAggFunctions

public static org.apache.sysml.runtime.functionobjects.ValueFunction[] getAggFunctions(SpoofCellwise.AggOp[] aggOps)