Class CpmmSPInstruction
- java.lang.Object
-
- org.apache.sysds.runtime.instructions.Instruction
-
- org.apache.sysds.runtime.instructions.spark.SPInstruction
-
- org.apache.sysds.runtime.instructions.spark.ComputationSPInstruction
-
- org.apache.sysds.runtime.instructions.spark.BinarySPInstruction
-
- org.apache.sysds.runtime.instructions.spark.AggregateBinarySPInstruction
-
- org.apache.sysds.runtime.instructions.spark.CpmmSPInstruction
-
- All Implemented Interfaces:
LineageTraceable
public class CpmmSPInstruction extends AggregateBinarySPInstruction
Cpmm: cross-product matrix multiplication operation (distributed matrix multiply by join over common dimension and subsequent aggregation of partial results). NOTE: There is additional optimization potential by preventing aggregation for a single block on the common dimension. However, in such a case we would never pick cpmm because this would result in a degree of parallelism of 1.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.sysds.runtime.instructions.spark.SPInstruction
SPInstruction.SPType
-
Nested classes/interfaces inherited from class org.apache.sysds.runtime.instructions.Instruction
Instruction.IType
-
-
Field Summary
-
Fields inherited from class org.apache.sysds.runtime.instructions.spark.ComputationSPInstruction
input1, input2, input3, output
-
Fields inherited from class org.apache.sysds.runtime.instructions.Instruction
DATATYPE_PREFIX, FEDERATED_INST_PREFIX, GPU_INST_PREFIX, INSTRUCTION_DELIM, LITERAL_PREFIX, OPERAND_DELIM, SP_INST_PREFIX, VALUETYPE_PREFIX
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description AggBinaryOp.SparkAggType
getAggType()
static CpmmSPInstruction
parseInstruction(String str)
void
processInstruction(ExecutionContext ec)
This method should be used to execute the instruction.-
Methods inherited from class org.apache.sysds.runtime.instructions.spark.ComputationSPInstruction
getLineageItem, getOutputVariableName
-
Methods inherited from class org.apache.sysds.runtime.instructions.spark.SPInstruction
getGraphString, getSPInstructionType, getType, postprocessInstruction, preprocessInstruction, requiresLabelUpdate
-
Methods inherited from class org.apache.sysds.runtime.instructions.Instruction
getBeginColumn, getBeginLine, getEndColumn, getEndLine, getExtendedOpcode, getFilename, getInstID, getInstructionString, getLineNum, getOpcode, getOperator, printMe, setInstID, setLocation, setLocation, setLocation, setLocation, toString, updateInstructionThreadID
-
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.sysds.runtime.lineage.LineageTraceable
getLineageItems, hasSingleLineage
-
-
-
-
Method Detail
-
parseInstruction
public static CpmmSPInstruction parseInstruction(String str)
-
processInstruction
public void processInstruction(ExecutionContext ec)
Description copied from class:Instruction
This method should be used to execute the instruction.- Specified by:
processInstruction
in classSPInstruction
- Parameters:
ec
- execution context
-
getAggType
public AggBinaryOp.SparkAggType getAggType()
-
-