public class SchedulingUtils extends Object
Constructor and Description |
---|
SchedulingUtils() |
Modifier and Type | Method and Description |
---|---|
static CompletableFuture<Void> |
schedule(ScheduleMode scheduleMode,
Iterable<ExecutionVertex> vertices,
ExecutionGraph executionGraph) |
static CompletableFuture<Void> |
scheduleEager(Iterable<ExecutionVertex> vertices,
ExecutionGraph executionGraph)
Schedule vertices eagerly.
|
static CompletableFuture<Void> |
scheduleLazy(Iterable<ExecutionVertex> vertices,
ExecutionGraph executionGraph)
Schedule vertices lazy.
|
public static CompletableFuture<Void> schedule(ScheduleMode scheduleMode, Iterable<ExecutionVertex> vertices, ExecutionGraph executionGraph)
public static CompletableFuture<Void> scheduleLazy(Iterable<ExecutionVertex> vertices, ExecutionGraph executionGraph)
vertices
- Topologically sorted vertices to schedule.executionGraph
- The graph the given vertices belong to.public static CompletableFuture<Void> scheduleEager(Iterable<ExecutionVertex> vertices, ExecutionGraph executionGraph)
vertices
- Topologically sorted vertices to schedule.executionGraph
- The graph the given vertices belong to.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.