@Internal public class StateLocalitySlotAssigner extends Object implements SlotAssigner
SlotAssigner
that assigns slots based on the number of local key groups.Constructor and Description |
---|
StateLocalitySlotAssigner() |
Modifier and Type | Method and Description |
---|---|
Collection<JobSchedulingPlan.SlotAssignment> |
assignSlots(JobInformation jobInformation,
Collection<? extends SlotInfo> freeSlots,
VertexParallelism vertexParallelism,
JobAllocationsInformation previousAllocations) |
Collection<org.apache.flink.runtime.scheduler.adaptive.allocator.StateLocalitySlotAssigner.AllocationScore> |
calculateScore(org.apache.flink.runtime.scheduler.adaptive.allocator.SlotSharingSlotAllocator.ExecutionSlotSharingGroup group,
Map<JobVertexID,Integer> parallelism,
JobInformation jobInformation,
JobAllocationsInformation previousAllocations) |
public Collection<JobSchedulingPlan.SlotAssignment> assignSlots(JobInformation jobInformation, Collection<? extends SlotInfo> freeSlots, VertexParallelism vertexParallelism, JobAllocationsInformation previousAllocations)
assignSlots
in interface SlotAssigner
public Collection<org.apache.flink.runtime.scheduler.adaptive.allocator.StateLocalitySlotAssigner.AllocationScore> calculateScore(org.apache.flink.runtime.scheduler.adaptive.allocator.SlotSharingSlotAllocator.ExecutionSlotSharingGroup group, Map<JobVertexID,Integer> parallelism, JobInformation jobInformation, JobAllocationsInformation previousAllocations)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.