public abstract class SpoofMultiAggregate extends SpoofOperator implements Serializable
SpoofOperator.SideInput, SpoofOperator.SideInputSparseCell, SpoofOperator.SideInputSparseRow| Constructor and Description | 
|---|
SpoofMultiAggregate(boolean sparseSafe,
                   SpoofCellwise.AggOp... aggOps)  | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
aggregatePartialResults(SpoofCellwise.AggOp[] aggOps,
                       MatrixBlock c,
                       MatrixBlock b)  | 
SpoofCUDAOperator | 
createCUDAInstrcution(Integer opID,
                     SpoofCUDAOperator.PrecisionProxy ep)  | 
MatrixBlock | 
execute(ArrayList<MatrixBlock> inputs,
       ArrayList<ScalarObject> scalarObjects,
       MatrixBlock out)  | 
MatrixBlock | 
execute(ArrayList<MatrixBlock> inputs,
       ArrayList<ScalarObject> scalarObjects,
       MatrixBlock out,
       int k)  | 
MatrixBlock | 
execute(ArrayList<MatrixBlock> inputs,
       ArrayList<ScalarObject> scalarObjects,
       MatrixBlock out,
       int k,
       long rix)  | 
static ValueFunction[] | 
getAggFunctions(SpoofCellwise.AggOp[] aggOps)  | 
SpoofCellwise.AggOp[] | 
getAggOps()  | 
static double | 
getInitialValue(SpoofCellwise.AggOp aggop)  | 
String | 
getSpoofType()  | 
boolean | 
isSparseSafe()  | 
execute, execute, getDenseMatrices, getTotalInputNnz, getTotalInputSizepublic SpoofMultiAggregate(boolean sparseSafe,
                           SpoofCellwise.AggOp... aggOps)
public SpoofCellwise.AggOp[] getAggOps()
public boolean isSparseSafe()
public String getSpoofType()
getSpoofType in class SpoofOperatorpublic SpoofCUDAOperator createCUDAInstrcution(Integer opID, SpoofCUDAOperator.PrecisionProxy ep)
createCUDAInstrcution in class SpoofOperatorpublic MatrixBlock execute(ArrayList<MatrixBlock> inputs, ArrayList<ScalarObject> scalarObjects, MatrixBlock out)
execute in class SpoofOperatorpublic MatrixBlock execute(ArrayList<MatrixBlock> inputs, ArrayList<ScalarObject> scalarObjects, MatrixBlock out, int k)
execute in class SpoofOperatorpublic MatrixBlock execute(ArrayList<MatrixBlock> inputs, ArrayList<ScalarObject> scalarObjects, MatrixBlock out, int k, long rix)
public static double getInitialValue(SpoofCellwise.AggOp aggop)
public static void aggregatePartialResults(SpoofCellwise.AggOp[] aggOps, MatrixBlock c, MatrixBlock b)
public static ValueFunction[] getAggFunctions(SpoofCellwise.AggOp[] aggOps)
Copyright © 2021 The Apache Software Foundation. All rights reserved.