Package | Description |
---|---|
org.apache.flink.runtime.scheduler.adaptive | |
org.apache.flink.runtime.scheduler.adaptive.allocator |
Modifier and Type | Method and Description |
---|---|
JobInformation.VertexInformation |
JobGraphJobInformation.getVertexInformation(JobVertexID jobVertexId) |
Modifier and Type | Method and Description |
---|---|
Iterable<JobInformation.VertexInformation> |
JobGraphJobInformation.getVertices() |
Modifier and Type | Method and Description |
---|---|
JobInformation.VertexInformation |
JobInformation.getVertexInformation(JobVertexID jobVertexId) |
Modifier and Type | Method and Description |
---|---|
ResourceCounter |
SlotAllocator.calculateRequiredSlots(Iterable<JobInformation.VertexInformation> vertices)
Calculates the total resources required for scheduling the given vertices.
|
ResourceCounter |
SlotSharingSlotAllocator.calculateRequiredSlots(Iterable<JobInformation.VertexInformation> vertices) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.