Modifier and Type | Method and Description |
---|---|
static ArrayList<Instruction> |
JMLCUtils.cleanupRuntimeInstructions(ArrayList<Instruction> insts,
HashSet<String> outputs)
Cleanup runtime instructions, removing rmvar instructions for
any of the given output variable names.
|
static ArrayList<Instruction> |
JMLCUtils.cleanupRuntimeInstructions(ArrayList<Instruction> insts,
String... outputs)
Cleanup runtime instructions, removing rmvar instructions for
any of the given output variable names.
|
Modifier and Type | Method and Description |
---|---|
static ArrayList<Instruction> |
JMLCUtils.cleanupRuntimeInstructions(ArrayList<Instruction> insts,
HashSet<String> outputs)
Cleanup runtime instructions, removing rmvar instructions for
any of the given output variable names.
|
static ArrayList<Instruction> |
JMLCUtils.cleanupRuntimeInstructions(ArrayList<Instruction> insts,
String... outputs)
Cleanup runtime instructions, removing rmvar instructions for
any of the given output variable names.
|
Modifier and Type | Method and Description |
---|---|
static ArrayList<Instruction> |
SpoofCompiler.generateCodeFromHopDAGsToInst(Hop root) |
static ArrayList<Instruction> |
SpoofCompiler.generateCodeFromHopDAGsToInst(StatementBlock sb,
ArrayList<Hop> roots) |
Modifier and Type | Method and Description |
---|---|
ArrayList<Instruction> |
Dag.getJobs(StatementBlock sb,
DMLConfig config)
Method to compile a dag generically
|
Modifier and Type | Method and Description |
---|---|
Instruction |
ProgramBlock.getExitInstruction() |
Instruction |
BasicProgramBlock.getInstruction(int i) |
Modifier and Type | Method and Description |
---|---|
ArrayList<Instruction> |
ForProgramBlock.getFromInstructions() |
ArrayList<Instruction> |
ForProgramBlock.getIncrementInstructions() |
ArrayList<Instruction> |
BasicProgramBlock.getInstructions() |
ArrayList<Instruction> |
IfProgramBlock.getPredicate() |
ArrayList<Instruction> |
WhileProgramBlock.getPredicate() |
ArrayList<Instruction> |
ForProgramBlock.getToInstructions() |
Modifier and Type | Method and Description |
---|---|
void |
BasicProgramBlock.addInstruction(Instruction inst) |
void |
ProgramBlock.setExitInstruction(Instruction rmVar) |
Modifier and Type | Method and Description |
---|---|
void |
BasicProgramBlock.addInstructions(ArrayList<Instruction> inst) |
ScalarObject |
ProgramBlock.executePredicate(ArrayList<Instruction> inst,
Hop hops,
boolean requiresRecompile,
Types.ValueType retType,
ExecutionContext ec)
Executes given predicate instructions (incl recompilation if required)
|
void |
ForProgramBlock.setFromInstructions(ArrayList<Instruction> instructions) |
void |
ForProgramBlock.setIncrementInstructions(ArrayList<Instruction> instructions) |
void |
BasicProgramBlock.setInstructions(ArrayList<Instruction> inst) |
void |
IfProgramBlock.setPredicate(ArrayList<Instruction> predicate) |
void |
WhileProgramBlock.setPredicate(ArrayList<Instruction> predicate) |
void |
ForProgramBlock.setToInstructions(ArrayList<Instruction> instructions) |
Constructor and Description |
---|
IfProgramBlock(Program prog,
ArrayList<Instruction> predicate) |
WhileProgramBlock(Program prog,
ArrayList<Instruction> predicate) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionContext.traceLineage(Instruction inst) |
Modifier and Type | Method and Description |
---|---|
static OptNode |
OptTreeConverter.createOptNode(Instruction inst,
LocalVariableMap vars,
boolean storeObjs) |
long |
OptTreePlanMappingRuntime.putMapping(Instruction inst,
OptNode n) |
Modifier and Type | Method and Description |
---|---|
static boolean |
OptTreeConverter.containsSparkInstruction(ArrayList<Instruction> instSet,
boolean inclCPFile) |
static ArrayList<OptNode> |
OptTreeConverter.createOptNodes(ArrayList<Instruction> instset,
LocalVariableMap vars,
boolean storeObjs) |
Modifier and Type | Method and Description |
---|---|
static Instruction[] |
InstructionParser.parseMixedInstructions(String str) |
static Instruction |
InstructionParser.parseSingleInstruction(String str) |
Instruction |
Instruction.preprocessInstruction(ExecutionContext ec)
This method should be used for any setup before executing this instruction.
|
Modifier and Type | Method and Description |
---|---|
void |
Instruction.setLocation(Instruction oldInst) |
Modifier and Type | Method and Description |
---|---|
static Instruction |
VariableCPInstruction.prepareCopyInstruction(String srcVar,
String destVar) |
static Instruction |
VariableCPInstruction.prepareRemoveInstruction(long... varName) |
static Instruction |
VariableCPInstruction.prepareRemoveInstruction(String... varNames) |
static Instruction |
VariableCPInstruction.prepCreatevarInstruction(String varName,
String fileName,
boolean fNameOverride,
String format) |
static Instruction |
VariableCPInstruction.prepCreatevarInstruction(String varName,
String fileName,
boolean fNameOverride,
Types.DataType dt,
String format,
DataCharacteristics mc,
MatrixObject.UpdateType update) |
static Instruction |
VariableCPInstruction.prepCreatevarInstruction(String varName,
String fileName,
boolean fNameOverride,
Types.DataType dt,
String format,
DataCharacteristics mc,
MatrixObject.UpdateType update,
boolean hasHeader,
String delim,
boolean sparse) |
static Instruction |
VariableCPInstruction.prepMoveInstruction(String srcVar,
String destVar) |
static Instruction |
VariableCPInstruction.prepMoveInstruction(String srcVar,
String destFileName,
String format) |
Instruction |
FunctionCallCPInstruction.preprocessInstruction(ExecutionContext ec) |
Instruction |
CPInstruction.preprocessInstruction(ExecutionContext ec) |
Modifier and Type | Class and Description |
---|---|
class |
MatrixIndexingCPFileInstruction
This instruction is used if a single partition is too large to fit in memory.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregateBinaryFEDInstruction |
class |
AggregateUnaryFEDInstruction |
class |
AppendFEDInstruction |
class |
BinaryFEDInstruction |
class |
BinaryMatrixMatrixFEDInstruction |
class |
BinaryMatrixScalarFEDInstruction |
class |
ComputationFEDInstruction |
class |
FEDInstruction |
class |
InitFEDInstruction |
class |
MMChainFEDInstruction |
class |
MultiReturnParameterizedBuiltinFEDInstruction |
class |
ParameterizedBuiltinFEDInstruction |
class |
ReorgFEDInstruction |
class |
TsmmFEDInstruction |
class |
UnaryFEDInstruction |
Modifier and Type | Method and Description |
---|---|
static Instruction |
FEDInstructionUtils.checkAndReplaceCP(Instruction inst,
ExecutionContext ec) |
static Instruction |
FEDInstructionUtils.checkAndReplaceSP(Instruction inst,
ExecutionContext ec) |
Instruction |
FEDInstruction.preprocessInstruction(ExecutionContext ec) |
Modifier and Type | Method and Description |
---|---|
static Instruction |
FEDInstructionUtils.checkAndReplaceCP(Instruction inst,
ExecutionContext ec) |
static Instruction |
FEDInstructionUtils.checkAndReplaceSP(Instruction inst,
ExecutionContext ec) |
Modifier and Type | Class and Description |
---|---|
class |
AggregateBinaryGPUInstruction |
class |
AggregateUnaryGPUInstruction
Implements aggregate unary instructions for CUDA
|
class |
ArithmeticBinaryGPUInstruction |
class |
BuiltinBinaryGPUInstruction |
class |
BuiltinUnaryGPUInstruction |
class |
DnnGPUInstruction |
class |
GPUInstruction |
class |
MatrixAppendGPUInstruction
Implements the cbind and rbind functions for matrices
|
class |
MatrixBuiltinGPUInstruction |
class |
MatrixIndexingGPUInstruction |
class |
MatrixMatrixArithmeticGPUInstruction |
class |
MatrixMatrixAxpyGPUInstruction |
class |
MatrixMatrixBuiltinGPUInstruction |
class |
MatrixMatrixRelationalBinaryGPUInstruction |
class |
MatrixReshapeGPUInstruction |
class |
MMTSJGPUInstruction |
class |
RelationalBinaryGPUInstruction |
class |
ReorgGPUInstruction |
class |
ScalarMatrixArithmeticGPUInstruction |
class |
ScalarMatrixBuiltinGPUInstruction |
class |
ScalarMatrixRelationalBinaryGPUInstruction |
Modifier and Type | Method and Description |
---|---|
Instruction |
GPUInstruction.preprocessInstruction(ExecutionContext ec) |
Modifier and Type | Method and Description |
---|---|
Instruction |
SPInstruction.preprocessInstruction(ExecutionContext ec) |
Modifier and Type | Method and Description |
---|---|
static boolean |
LineageRewriteReuse.executeRewrites(Instruction curr,
ExecutionContext ec) |
static boolean |
LineageCacheConfig.isReusable(Instruction inst,
ExecutionContext ec) |
static void |
LineageCache.putMatrix(Instruction inst,
ExecutionContext ec,
long computetime) |
static void |
LineageCache.putValue(Instruction inst,
ExecutionContext ec,
long starttime) |
static boolean |
LineageCache.reuse(Instruction inst,
ExecutionContext ec) |
void |
Lineage.trace(Instruction inst,
ExecutionContext ec) |
void |
LineageMap.trace(Instruction inst,
ExecutionContext ec) |
Modifier and Type | Method and Description |
---|---|
static void |
PrivacyPropagator.postProcessInstruction(Instruction inst,
ExecutionContext ec) |
static Instruction |
PrivacyPropagator.preprocessInstruction(Instruction inst,
ExecutionContext ec) |
static Instruction |
PrivacyPropagator.preprocessInstructionSimple(Instruction inst,
ExecutionContext ec)
Throw exception if privacy constraints are activated or return instruction if privacy is not activated
|
Modifier and Type | Method and Description |
---|---|
static Instruction |
ProgramConverter.cloneInstruction(Instruction oInst,
long pid,
boolean plain,
boolean cpFunctions) |
Modifier and Type | Method and Description |
---|---|
static ArrayList<Instruction> |
ProgramConverter.createDeepCopyInstructionSet(ArrayList<Instruction> instSet,
long pid,
int IDPrefix,
Program prog,
Set<String> fnStack,
Set<String> fnCreated,
boolean plain,
boolean cpFunctions)
Creates a deep copy of an array of instructions and replaces the placeholders of parworker
IDs with the concrete IDs of this parfor instance.
|
Modifier and Type | Method and Description |
---|---|
static Instruction |
ProgramConverter.cloneInstruction(Instruction oInst,
long pid,
boolean plain,
boolean cpFunctions) |
Modifier and Type | Method and Description |
---|---|
static ArrayList<Instruction> |
ProgramConverter.createDeepCopyInstructionSet(ArrayList<Instruction> instSet,
long pid,
int IDPrefix,
Program prog,
Set<String> fnStack,
Set<String> fnCreated,
boolean plain,
boolean cpFunctions)
Creates a deep copy of an array of instructions and replaces the placeholders of parworker
IDs with the concrete IDs of this parfor instance.
|
Modifier and Type | Method and Description |
---|---|
static String |
Explain.explain(Instruction inst) |
static String |
Statistics.getCPHeavyHitterCode(Instruction inst) |
Modifier and Type | Method and Description |
---|---|
static String |
Explain.explain(ArrayList<Instruction> inst) |
static String |
Explain.explain(ArrayList<Instruction> inst,
int level) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.