public class MapMult extends Lop
| Modifier and Type | Class and Description |
|---|---|
static class |
MapMult.CacheType |
Lop.SimpleInstType, Lop.Type, Lop.VisitStatus| Modifier and Type | Field and Description |
|---|---|
static String |
OPCODE |
_beginColumn, _beginLine, _endColumn, _endLine, _filename, CP_CHILD_THREAD, CP_ROOT_THREAD_ID, DATATYPE_PREFIX, FILE_SEPARATOR, FRAME_VAR_NAME_PREFIX, INSTRUCTION_DELIMITOR, LITERAL_PREFIX, MATRIX_VAR_NAME_PREFIX, NAME_VALUE_SEPARATOR, OPERAND_DELIMITOR, PROCESS_PREFIX, SAMPLE_FRACTION, SCALAR_VAR_NAME_PREFIX, UPDATE_INPLACE_PREFIX, VALUETYPE_PREFIX, VARIABLE_NAME_PLACEHOLDER| Constructor and Description |
|---|
MapMult(Lop input1,
Lop input2,
Types.DataType dt,
Types.ValueType vt,
boolean rightCache,
boolean partitioned,
boolean emptyBlocks,
AggBinaryOp.SparkAggType aggtype)
Constructor to setup a partial Matrix-Vector Multiplication for Spark
|
| Modifier and Type | Method and Description |
|---|---|
AggBinaryOp.SparkAggType |
getAggType()
Method to get aggregate type if applicable.
|
Lop |
getBroadcastInput()
Method to get the input to be broadcast.
|
String |
getInstructions(String input1,
String input2,
String output)
Method should be overridden if needed
|
String |
toString()
Method to have Lops print their state.
|
addInput, addOutput, addToDag, createReachable, getBeginColumn, getBeginLine, getDataType, getEndColumn, getEndLine, getExecType, getFilename, getID, getInputs, getInstructions, getInstructions, getInstructions, getInstructions, getInstructions, getInstructions, getInstructions, getInstructions, getInstructions, getInstructions, getInstructions, getLevel, getOutputParameters, getOutputs, getPrivacyConstraint, getProducesIntermediateOutput, getReachable, getSimpleInstructionType, getType, getValueType, getVisited, isAllOutputsCP, isDataExecLocation, isVariable, prepInputOperand, prepInputOperand, prepOperand, prepOperand, prepOutputOperand, prepOutputOperand, prepOutputOperand, prepScalarInputOperand, prepScalarInputOperand, prepScalarLabel, prepScalarOperand, printErrorLocation, removeConsumer, removeOutput, replaceInput, resetVisitStatus, setAllPositions, setBeginColumn, setBeginLine, setConsumerCount, setDataType, setEndColumn, setEndLine, setExecType, setFederatedOutput, setFilename, setPrivacyConstraint, setValueType, setVisitedpublic static final String OPCODE
public MapMult(Lop input1, Lop input2, Types.DataType dt, Types.ValueType vt, boolean rightCache, boolean partitioned, boolean emptyBlocks, AggBinaryOp.SparkAggType aggtype)
input1 - low-level operator 1input2 - low-level operator 2dt - data typevt - value typerightCache - true if right cache, false if left cachepartitioned - true if partitioned, false if not partitionedemptyBlocks - true if output empty blocksaggtype - spark aggregation typepublic AggBinaryOp.SparkAggType getAggType()
LopgetAggType in class Loppublic Lop getBroadcastInput()
LopgetBroadcastInput in class Loppublic String toString()
LopCopyright © 2021 The Apache Software Foundation. All rights reserved.