public class DefaultSlotAssigner extends Object implements SlotAssigner
SlotAssigner
that treats all slots and slot sharing groups equally.Constructor and Description |
---|
DefaultSlotAssigner() |
Modifier and Type | Method and Description |
---|---|
Collection<JobSchedulingPlan.SlotAssignment> |
assignSlots(JobInformation jobInformation,
Collection<? extends SlotInfo> freeSlots,
VertexParallelism vertexParallelism,
JobAllocationsInformation previousAllocations) |
public Collection<JobSchedulingPlan.SlotAssignment> assignSlots(JobInformation jobInformation, Collection<? extends SlotInfo> freeSlots, VertexParallelism vertexParallelism, JobAllocationsInformation previousAllocations)
assignSlots
in interface SlotAssigner
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.