| 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) | 
| 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,
      ArrayList<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 © 2020 The Apache Software Foundation. All rights reserved.