| Package | Description | 
|---|---|
| org.apache.sysds.runtime.controlprogram.parfor | 
| Modifier and Type | Method and Description | 
|---|---|
| static Task | Task. parseCompactString(String stask) | 
| Modifier and Type | Method and Description | 
|---|---|
| abstract List<Task> | TaskPartitioner. createTasks()Creates and returns set of all tasks for given problem at once. | 
| List<Task> | TaskPartitionerFactoring. createTasks() | 
| List<Task> | TaskPartitionerFixedsize. createTasks() | 
| Modifier and Type | Method and Description | 
|---|---|
| Iterator<scala.Tuple2<Long,String>> | RemoteParForSparkWorker. call(Task arg0) | 
| Modifier and Type | Method and Description | 
|---|---|
| abstract long | TaskPartitioner. createTasks(LocalTaskQueue<Task> queue)Creates set of all tasks for given problem, but streams them directly
 into task queue. | 
| long | TaskPartitionerFactoring. createTasks(LocalTaskQueue<Task> queue) | 
| long | TaskPartitionerFixedsize. createTasks(LocalTaskQueue<Task> queue) | 
| 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) | 
| Constructor and Description | 
|---|
| LocalParWorker(long ID,
              LocalTaskQueue<Task> q,
              ParForBody body,
              CompilerConfig cconf,
              int max_retry,
              boolean monitor) | 
Copyright © 2020 The Apache Software Foundation. All rights reserved.