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.