Package org.apache.flink.runtime.jobmaster.slotpool

Class PhysicalSlotRequest

java.lang.Object

org.apache.flink.runtime.jobmaster.slotpool.PhysicalSlotRequest

All Implemented Interfaces:

WeightLoadable

public class PhysicalSlotRequest
extends Object
implements WeightLoadable

Represents a request for a physical slot.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PhysicalSlotRequest.Result	Result of a PhysicalSlotRequest.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
LoadingWeight	getLoading()	Get the loading weight.
ResourceProfile	getPhysicalSlotResourceProfile()
SlotProfile	getSlotProfile()
SlotRequestId	getSlotRequestId()
boolean	willSlotBeOccupiedIndefinitely()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PhysicalSlotRequest

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

Method Detail

getSlotRequestId

public SlotRequestId getSlotRequestId()

getSlotProfile

public SlotProfile getSlotProfile()

getPhysicalSlotResourceProfile

public ResourceProfile getPhysicalSlotResourceProfile()

willSlotBeOccupiedIndefinitely

public boolean willSlotBeOccupiedIndefinitely()

getLoading

@Nonnull
public LoadingWeight getLoading()

Description copied from interface: WeightLoadable

Get the loading weight.

Specified by:

getLoading in interface WeightLoadable

Returns:

An implementation object of LoadingWeight.