Package | Description |
---|---|
org.apache.sysds.runtime.controlprogram.parfor |
Modifier and Type | Method and Description |
---|---|
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) |
static RemoteParForJobReturn |
RemoteDPParForSpark.runJob(long pfid,
String itervar,
String matrixvar,
String program,
HashMap<String,byte[]> clsMap,
String resultFile,
MatrixObject input,
ExecutionContext ec,
ParForProgramBlock.PartitionFormat dpf,
Types.FileFormat fmt,
boolean tSparseCol,
boolean enableCPCaching,
int numReducers) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.