public class CSVReblockSPInstruction extends UnarySPInstruction
SPInstruction.SPINSTRUCTION_TYPE
Instruction.INSTRUCTION_TYPE
input1, input2, input3, output
_optr, _requiresLabelUpdate, _sptype
beginCol, beginLine, DATATYPE_PREFIX, endCol, endLine, filename, GPU_INST_PREFIX, instOpcode, INSTRUCTION_DELIM, instString, LITERAL_PREFIX, LOG, OPERAND_DELIM, SP_INST_PREFIX, type, VALUETYPE_PREFIX
Modifier | Constructor and Description |
---|---|
protected |
CSVReblockSPInstruction(org.apache.sysml.runtime.matrix.operators.Operator op,
org.apache.sysml.runtime.instructions.cp.CPOperand in,
org.apache.sysml.runtime.instructions.cp.CPOperand out,
int br,
int bc,
boolean hasHeader,
String delim,
boolean fill,
double fillValue,
String opcode,
String instr) |
Modifier and Type | Method and Description |
---|---|
static CSVReblockSPInstruction |
parseInstruction(String str) |
protected org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> |
processFrameCSVReblockInstruction(org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sec,
MatrixCharacteristics mcOut,
org.apache.sysml.parser.Expression.ValueType[] schema) |
void |
processInstruction(org.apache.sysml.runtime.controlprogram.context.ExecutionContext ec)
This method should be used to execute the instruction.
|
protected org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> |
processMatrixCSVReblockInstruction(org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sec,
MatrixCharacteristics mcOut) |
getOutputVariableName, updateBinaryOutputMatrixCharacteristics, updateUnaryAggOutputMatrixCharacteristics, updateUnaryOutputMatrixCharacteristics, updateUnaryOutputMatrixCharacteristics
getGraphString, getSPInstructionType, postprocessInstruction, preprocessInstruction, requiresLabelUpdate
getBeginColumn, getBeginLine, getEndColumn, getEndLine, getExtendedOpcode, getFilename, getInstID, getLineNum, getOpcode, getType, printMe, setInstID, setLocation, setLocation, setLocation, setLocation, setType, toString, updateInstructionThreadID
protected CSVReblockSPInstruction(org.apache.sysml.runtime.matrix.operators.Operator op, org.apache.sysml.runtime.instructions.cp.CPOperand in, org.apache.sysml.runtime.instructions.cp.CPOperand out, int br, int bc, boolean hasHeader, String delim, boolean fill, double fillValue, String opcode, String instr)
public static CSVReblockSPInstruction parseInstruction(String str) throws DMLRuntimeException
DMLRuntimeException
public void processInstruction(org.apache.sysml.runtime.controlprogram.context.ExecutionContext ec) throws DMLRuntimeException
Instruction
processInstruction
in class SPInstruction
ec
- execution contextDMLRuntimeException
- if DMLRuntimeException occursprotected org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> processMatrixCSVReblockInstruction(org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sec, MatrixCharacteristics mcOut) throws DMLRuntimeException
DMLRuntimeException
protected org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> processFrameCSVReblockInstruction(org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sec, MatrixCharacteristics mcOut, org.apache.sysml.parser.Expression.ValueType[] schema) throws DMLRuntimeException
DMLRuntimeException
Copyright © 2017 The Apache Software Foundation. All rights reserved.