| Modifier and Type | Method and Description | 
|---|---|
LocalVariableMap | 
MLResults.getSymbolTable()
Obtain the symbol table, which is essentially a  
Map<String, Data>
 representing variables and their values as SystemDS representations. | 
LocalVariableMap | 
Script.getSymbolTable()
Obtain the symbol table, which is essentially a
  
HashMap<String, Data> representing variables and their values. | 
| 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,
                              boolean inplace,
                              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)  | 
static ExecutionContext | 
ParamservUtils.createExecutionContext(ExecutionContext ec,
                      LocalVariableMap varsMap,
                      String updFunc,
                      String aggFunc,
                      int k,
                      boolean forceExecTypeCP)  | 
| Modifier and Type | Method and Description | 
|---|---|
static LocalVariableMap[] | 
RemoteParForUtils.getResults(List<scala.Tuple2<Long,String>> out,
          org.apache.commons.logging.Log LOG)  | 
LocalVariableMap[] | 
RemoteParForJobReturn.getVariables()  | 
LocalVariableMap | 
ParForBody.getVariables()  | 
LocalVariableMap | 
ParWorker.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 © 2021 The Apache Software Foundation. All rights reserved.