Modifier and Type | Method and Description |
---|---|
LocalVariableMap |
Script.getSymbolTable()
Obtain the symbol table, which is essentially a
HashMap<String, Data> representing variables and their values. |
LocalVariableMap |
MLResults.getSymbolTable()
Obtain the symbol table, which is essentially a
Map<String, Data>
representing variables and their values as SystemDS representations. |
Modifier and Type | Method and Description |
---|---|
static String |
MLContextUtil.determineOutputTypeAsString(LocalVariableMap symbolTable,
String outputName)
Obtain a symbol table output type as a String
|
static String |
MLContextUtil.displayInputs(String name,
Map<String,Object> map,
LocalVariableMap symbolTable)
Obtain a display of script inputs.
|
static String |
MLContextUtil.displayOutputs(Set<String> outputNames,
LocalVariableMap symbolTable)
Obtain a display of the script outputs.
|
static String |
MLContextUtil.displayOutputs(String name,
Set<String> outputNames,
LocalVariableMap symbolTable)
Obtain a display of the script outputs.
|
static String |
MLContextUtil.displaySymbolTable(LocalVariableMap symbolTable)
Display the keys and values in the symbol table
|
static String |
MLContextUtil.displaySymbolTable(String name,
LocalVariableMap symbolTable)
Display the keys and values in the symbol table
|
static boolean |
MLContextUtil.doesSymbolTableContainFrameObject(LocalVariableMap symbolTable,
String variableName)
Determine if the symbol table contains a FrameObject with the given
variable name.
|
static boolean |
MLContextUtil.doesSymbolTableContainMatrixObject(LocalVariableMap symbolTable,
String variableName)
Determine if the symbol table contains a MatrixObject with the given
variable name.
|
Constructor and Description |
---|
MLResults(LocalVariableMap symbolTable) |
Modifier and Type | Method and Description |
---|---|
double |
CostEstimator.getTimeEstimate(ProgramBlock pb,
LocalVariableMap vars,
HashMap<String,VarStats> stats,
boolean recursive) |
double |
CostEstimator.getTimeEstimate(Program rtprog,
LocalVariableMap vars,
HashMap<String,VarStats> stats) |
Modifier and Type | Method and Description |
---|---|
static LocalVariableMap |
Recompiler.reconcileUpdatedCallVarsIf(LocalVariableMap oldCallVars,
LocalVariableMap callVarsIf,
LocalVariableMap callVarsElse,
StatementBlock sb) |
Modifier and Type | Method and Description |
---|---|
static void |
Recompiler.extractDAGOutputStatistics(ArrayList<Hop> hops,
LocalVariableMap vars) |
static void |
Recompiler.extractDAGOutputStatistics(ArrayList<Hop> hops,
LocalVariableMap vars,
boolean overwrite) |
static void |
Recompiler.extractDAGOutputStatistics(Hop hop,
LocalVariableMap vars,
boolean overwrite) |
static ArrayList<Instruction> |
Recompiler.recompileHopsDag(Hop hop,
LocalVariableMap vars,
RecompileStatus status,
boolean inplace,
boolean replaceLit,
long tid) |
static ArrayList<Instruction> |
Recompiler.recompileHopsDag(StatementBlock sb,
ArrayList<Hop> hops,
LocalVariableMap vars,
RecompileStatus status,
boolean inplace,
boolean replaceLit,
long tid) |
static void |
Recompiler.recompileProgramBlockHierarchy(ArrayList<ProgramBlock> pbs,
LocalVariableMap vars,
long tid,
Recompiler.ResetType resetRecompile) |
static LocalVariableMap |
Recompiler.reconcileUpdatedCallVarsIf(LocalVariableMap oldCallVars,
LocalVariableMap callVarsIf,
LocalVariableMap callVarsElse,
StatementBlock sb) |
static boolean |
Recompiler.reconcileUpdatedCallVarsLoops(LocalVariableMap oldCallVars,
LocalVariableMap callVars,
StatementBlock sb) |
static void |
Recompiler.removeUpdatedScalars(LocalVariableMap callVars,
StatementBlock sb)
Remove any scalar variables from the variable map if the variable
is updated in this block.
|
static void |
Recompiler.rReplaceLiterals(Hop hop,
LocalVariableMap vars,
boolean scalarsOnly) |
static void |
Recompiler.rUpdateStatistics(Hop hop,
LocalVariableMap vars) |
Modifier and Type | Method and Description |
---|---|
LocalVariableMap |
ProgramRewriteStatus.getVariables() |
Constructor and Description |
---|
ProgramRewriteStatus(LocalVariableMap vars) |
RewriteRemovePersistentReadWrite(String[] in,
String[] out,
LocalVariableMap vars) |
Modifier and Type | Method and Description |
---|---|
static LocalVariableMap |
LocalVariableMap.deserialize(String varStr) |
Modifier and Type | Method and Description |
---|---|
void |
LocalVariableMap.putAll(LocalVariableMap vars) |
Constructor and Description |
---|
LocalVariableMap(LocalVariableMap vars) |
Modifier and Type | Method and Description |
---|---|
LocalVariableMap |
ExecutionContext.getVariables() |
Modifier and Type | Method and Description |
---|---|
static ExecutionContext |
ExecutionContextFactory.createContext(LocalVariableMap vars,
Program prog) |
void |
ExecutionContext.setVariables(LocalVariableMap vars) |
Constructor and Description |
---|
ExecutionContext(LocalVariableMap vars) |
Modifier and Type | Method and Description |
---|---|
static ExecutionContext |
ParamservUtils.createExecutionContext(ExecutionContext ec,
LocalVariableMap varsMap,
String updFunc,
String aggFunc,
int k) |
Modifier and Type | Method and Description |
---|---|
static LocalVariableMap[] |
RemoteParForUtils.getResults(List<scala.Tuple2<Long,String>> out,
org.apache.commons.logging.Log LOG) |
LocalVariableMap |
ParWorker.getVariables() |
LocalVariableMap |
ParForBody.getVariables() |
LocalVariableMap[] |
RemoteParForJobReturn.getVariables() |
Modifier and Type | Method and Description |
---|---|
static void |
RemoteParForUtils.exportLineageItems(long workerID,
LocalVariableMap vars,
ArrayList<ParForStatementBlock.ResultVar> resultVars,
Lineage lineage)
Export lineage for remote Spark parfor workers.
|
static ArrayList<String> |
RemoteParForUtils.exportResultVariables(long workerID,
LocalVariableMap vars,
ArrayList<ParForStatementBlock.ResultVar> resultVars)
For remote Spark parfor workers.
|
static void |
RemoteParForUtils.exportResultVariables(long workerID,
LocalVariableMap vars,
ArrayList<ParForStatementBlock.ResultVar> resultVars,
HashMap<String,String> rvarFnames,
org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> out)
For remote MR parfor workers.
|
static void |
RemoteParForUtils.exportResultVariables(long workerID,
LocalVariableMap vars,
ArrayList<ParForStatementBlock.ResultVar> resultVars,
org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> out) |
static Lineage[] |
RemoteParForUtils.getLineages(LocalVariableMap[] results) |
void |
CachedReuseVariables.reuseVariables(long pfid,
LocalVariableMap vars,
Collection<String> excludeList,
Map<String,org.apache.spark.broadcast.Broadcast<CacheBlock>> _brInputs,
boolean cleanCache) |
Constructor and Description |
---|
RemoteParForJobReturn(boolean successful,
int numTasks,
int numIters,
LocalVariableMap[] variables) |
RemoteParForJobReturn(boolean successful,
int numTasks,
int numIters,
LocalVariableMap[] variables,
Lineage[] lineages) |
Modifier and Type | Method and Description |
---|---|
static LocalVariableMap |
ProgramRecompiler.getReusableScalarVariables(DMLProgram prog,
StatementBlock parforSB,
LocalVariableMap vars) |
Constructor and Description |
---|
CostEstimatorRuntime(OptTreePlanMappingAbstract map,
LocalVariableMap vars) |
Modifier and Type | Method and Description |
---|---|
static String |
CPInstruction.updateLabels(String instList,
LocalVariableMap labelValueMapping)
Takes a delimited string of instructions, and replaces ALL placeholder labels
(such as ##mVar2## and ##Var5##) in ALL instructions.
|
Copyright © 2020 The Apache Software Foundation. All rights reserved.