Uses of Class
org.apache.flink.runtime.jobmaster.SlotRequestId
-
Packages that use SlotRequestId Package Description org.apache.flink.runtime.jobmaster org.apache.flink.runtime.jobmaster.slotpool -
-
Uses of SlotRequestId in org.apache.flink.runtime.jobmaster
Methods in org.apache.flink.runtime.jobmaster that return SlotRequestId Modifier and Type Method Description SlotRequestIdLogicalSlot. getSlotRequestId()Gets the slot request id uniquely identifying the request with which this slot has been allocated. -
Uses of SlotRequestId in org.apache.flink.runtime.jobmaster.slotpool
Methods in org.apache.flink.runtime.jobmaster.slotpool that return SlotRequestId Modifier and Type Method Description SlotRequestIdPhysicalSlotRequest. getSlotRequestId()SlotRequestIdPhysicalSlotRequest.Result. getSlotRequestId()SlotRequestIdSingleLogicalSlot. getSlotRequestId()Methods in org.apache.flink.runtime.jobmaster.slotpool that return types with arguments of type SlotRequestId Modifier and Type Method Description Map<SlotRequestId,CompletableFuture<PhysicalSlotRequest.Result>>PhysicalSlotProvider. allocatePhysicalSlots(Collection<PhysicalSlotRequest> physicalSlotRequests)Submit requests to allocate physical slots.Map<SlotRequestId,CompletableFuture<PhysicalSlotRequest.Result>>PhysicalSlotProviderImpl. allocatePhysicalSlots(Collection<PhysicalSlotRequest> physicalSlotRequests)Methods in org.apache.flink.runtime.jobmaster.slotpool with parameters of type SlotRequestId Modifier and Type Method Description static SingleLogicalSlotSingleLogicalSlot. allocateFromPhysicalSlot(SlotRequestId slotRequestId, PhysicalSlot physicalSlot, Locality locality, SlotOwner slotOwner, boolean slotWillBeOccupiedIndefinitely)voidPhysicalSlotProvider. cancelSlotRequest(SlotRequestId slotRequestId, Throwable cause)Cancels the slot request with the givenSlotRequestId.voidPhysicalSlotProviderImpl. cancelSlotRequest(SlotRequestId slotRequestId, Throwable cause)voidAllocatedSlotActions. releaseSlot(SlotRequestId slotRequestId, Throwable cause)Releases the slot with the givenSlotRequestId.voidDeclarativeSlotPoolBridge. releaseSlot(SlotRequestId slotRequestId, Throwable cause)Constructors in org.apache.flink.runtime.jobmaster.slotpool with parameters of type SlotRequestId Constructor Description PhysicalSlotRequest(SlotRequestId slotRequestId, SlotProfile slotProfile, LoadingWeight loadingWeight, boolean slotWillBeOccupiedIndefinitely)Result(SlotRequestId slotRequestId, PhysicalSlot physicalSlot)SingleLogicalSlot(SlotRequestId slotRequestId, SlotContext slotContext, Locality locality, SlotOwner slotOwner)SingleLogicalSlot(SlotRequestId slotRequestId, SlotContext slotContext, Locality locality, SlotOwner slotOwner, boolean willBeOccupiedIndefinitely)
-