| Package | Description | 
|---|---|
| org.apache.sysds.parser | |
| org.apache.sysds.runtime.controlprogram | |
| org.apache.sysds.runtime.controlprogram.parfor | |
| org.apache.sysds.runtime.util | 
| Modifier and Type | Method and Description | 
|---|---|
ArrayList<ParForStatementBlock.ResultVar> | 
ParForStatementBlock.getResultVariables()  | 
| Modifier and Type | Method and Description | 
|---|---|
static boolean | 
ParForStatementBlock.ResultVar.contains(Collection<ParForStatementBlock.ResultVar> list,
        String varName)  | 
void | 
ParForStatementBlock.setResultVariables(ArrayList<ParForStatementBlock.ResultVar> rvars)  | 
| Modifier and Type | Method and Description | 
|---|---|
ArrayList<ParForStatementBlock.ResultVar> | 
ParForProgramBlock.getResultVariables()  | 
| Constructor and Description | 
|---|
ParForProgramBlock(int ID,
                  Program prog,
                  String iterPredVar,
                  HashMap<String,String> params,
                  ArrayList<ParForStatementBlock.ResultVar> resultVars)
ParForProgramBlock constructor. 
 | 
ParForProgramBlock(Program prog,
                  String iterPredVar,
                  HashMap<String,String> params,
                  ArrayList<ParForStatementBlock.ResultVar> resultVars)  | 
| Modifier and Type | Method and Description | 
|---|---|
ArrayList<ParForStatementBlock.ResultVar> | 
ParForBody.getResultVariables()  | 
| 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 RemoteParForJobReturn | 
RemoteParForSpark.runJob(long pfid,
      String prog,
      HashMap<String,byte[]> clsMap,
      List<Task> tasks,
      ExecutionContext ec,
      Set<String> brVars,
      List<ParForStatementBlock.ResultVar> resultVars,
      boolean cpCaching,
      int numMappers,
      boolean topLevelPF)  | 
void | 
ParForBody.setResultVariables(ArrayList<ParForStatementBlock.ResultVar> resultVars)  | 
| Constructor and Description | 
|---|
ParForBody(ArrayList<ProgramBlock> childBlocks,
          ArrayList<ParForStatementBlock.ResultVar> resultVars,
          ExecutionContext ec)  | 
| Modifier and Type | Method and Description | 
|---|---|
static String | 
ProgramConverter.serializeResultVariables(List<ParForStatementBlock.ResultVar> vars)  | 
Copyright © 2021 The Apache Software Foundation. All rights reserved.