public class MultiComputeTasksGraphExample extends TaskWorker
SourceTask (Two Outgoing Edges) | | (Direct Communication) V V FirstComputeTask SecondComputeTask | | (All-Reduce Communication) V V ReduceTask (Two Incoming Edges)
Modifier and Type | Class and Description |
---|---|
class |
MultiComputeTasksGraphExample.Aggregator |
computeEnvironment, config, persistentVolume, taskExecutor, volatileVolume, workerController, workerEnvironment, workerId
Constructor and Description |
---|
MultiComputeTasksGraphExample() |
Modifier and Type | Method and Description |
---|---|
void |
execute()
A user needs to implement this method to create the task graph and execute it
|
static void |
main(java.lang.String[] args) |
execute
public void execute()
TaskWorker
execute
in class TaskWorker
public static void main(java.lang.String[] args) throws ParseException
ParseException