@Internal public class JobSchedulingPlan extends Object
JobGraph
.
vertexParallelism
is necessary to create ExecutionGraph
slotAssignments
are used to schedule it onto the cluster
AdaptiveScheduler
passes this structure from WaitingForResources
to CreatingExecutionGraph
stages.Modifier and Type | Class and Description |
---|---|
static class |
JobSchedulingPlan.SlotAssignment
Assignment of a slot to some target (e.g.
|
Constructor and Description |
---|
JobSchedulingPlan(VertexParallelism vertexParallelism,
Collection<JobSchedulingPlan.SlotAssignment> slotAssignments) |
Modifier and Type | Method and Description |
---|---|
static JobSchedulingPlan |
empty()
Create an empty
JobSchedulingPlan with no information about vertices or allocations. |
Collection<JobSchedulingPlan.SlotAssignment> |
getSlotAssignments() |
VertexParallelism |
getVertexParallelism() |
String |
toString() |
public JobSchedulingPlan(VertexParallelism vertexParallelism, Collection<JobSchedulingPlan.SlotAssignment> slotAssignments)
public VertexParallelism getVertexParallelism()
public Collection<JobSchedulingPlan.SlotAssignment> getSlotAssignments()
public static JobSchedulingPlan empty()
JobSchedulingPlan
with no information about vertices or allocations.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.