Uses of Interface
org.apache.flink.runtime.scheduler.loading.LoadingWeight

Packages that use LoadingWeight

Package	Description
org.apache.flink.runtime.jobmaster.slotpool
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adaptive.allocator
org.apache.flink.runtime.scheduler.loading

Uses of LoadingWeight in org.apache.flink.runtime.jobmaster.slotpool

Methods in org.apache.flink.runtime.jobmaster.slotpool that return LoadingWeight

Modifier and Type	Method	Description
LoadingWeight	PhysicalSlotRequest.getLoading()

Method parameters in org.apache.flink.runtime.jobmaster.slotpool with type arguments of type LoadingWeight

Modifier and Type	Method	Description
Collection<RequestSlotMatchingStrategy.RequestSlotMatch>	PreferredAllocationRequestSlotMatchingStrategy.matchRequestsAndSlots(Collection<? extends PhysicalSlot> slots, Collection<org.apache.flink.runtime.jobmaster.slotpool.PendingRequest> pendingRequests, Map<ResourceID,LoadingWeight> taskExecutorsLoadingWeight)
Collection<RequestSlotMatchingStrategy.RequestSlotMatch>	RequestSlotMatchingStrategy.matchRequestsAndSlots(Collection<? extends PhysicalSlot> slots, Collection<org.apache.flink.runtime.jobmaster.slotpool.PendingRequest> pendingRequests, Map<ResourceID,LoadingWeight> taskExecutorsLoadingWeight)	Match the given slots with the given collection of pending requests.
Collection<RequestSlotMatchingStrategy.RequestSlotMatch>	SimpleRequestSlotMatchingStrategy.matchRequestsAndSlots(Collection<? extends PhysicalSlot> slots, Collection<org.apache.flink.runtime.jobmaster.slotpool.PendingRequest> pendingRequests, Map<ResourceID,LoadingWeight> taskExecutorsLoadingWeight)
Collection<RequestSlotMatchingStrategy.RequestSlotMatch>	TasksBalancedRequestSlotMatchingStrategy.matchRequestsAndSlots(Collection<? extends PhysicalSlot> slots, Collection<org.apache.flink.runtime.jobmaster.slotpool.PendingRequest> pendingRequests, Map<ResourceID,LoadingWeight> taskExecutorsLoad)

Constructors in org.apache.flink.runtime.jobmaster.slotpool with parameters of type LoadingWeight

Constructor	Description
PhysicalSlotRequest(SlotRequestId slotRequestId, SlotProfile slotProfile, LoadingWeight loadingWeight, boolean slotWillBeOccupiedIndefinitely)

Uses of LoadingWeight in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler that return LoadingWeight

Modifier and Type	Method	Description
LoadingWeight	ExecutionSlotSharingGroup.getLoading()

Uses of LoadingWeight in org.apache.flink.runtime.scheduler.adaptive.allocator

Methods in org.apache.flink.runtime.scheduler.adaptive.allocator that return LoadingWeight

Modifier and Type	Method	Description
LoadingWeight	SlotSharingSlotAllocator.ExecutionSlotSharingGroup.getLoading()

Uses of LoadingWeight in org.apache.flink.runtime.scheduler.loading

Classes in org.apache.flink.runtime.scheduler.loading that implement LoadingWeight

Modifier and Type	Class	Description
class	DefaultLoadingWeight	The default implementation of LoadingWeight.

Fields in org.apache.flink.runtime.scheduler.loading declared as LoadingWeight

Modifier and Type	Field	Description
static LoadingWeight	DefaultLoadingWeight.EMPTY

Methods in org.apache.flink.runtime.scheduler.loading that return LoadingWeight

Modifier and Type	Method	Description
LoadingWeight	WeightLoadable.getLoading()	Get the loading weight.
LoadingWeight	DefaultLoadingWeight.merge(LoadingWeight other)
LoadingWeight	LoadingWeight.merge(LoadingWeight other)	Merge the other loading weight and this one into a new object.

Methods in org.apache.flink.runtime.scheduler.loading with parameters of type LoadingWeight

Modifier and Type	Method	Description
int	DefaultLoadingWeight.compareTo(LoadingWeight o)
LoadingWeight	DefaultLoadingWeight.merge(LoadingWeight other)
LoadingWeight	LoadingWeight.merge(LoadingWeight other)	Merge the other loading weight and this one into a new object.