Uses of Class
org.apache.flink.runtime.clusterframework.types.SlotID
-
-
Uses of SlotID in org.apache.flink.runtime.clusterframework.types
Methods in org.apache.flink.runtime.clusterframework.types that return SlotID Modifier and Type Method Description static SlotIDSlotID. getDynamicSlotID(ResourceID resourceID)Get a SlotID without actual slot index for dynamic slot allocation. -
Uses of SlotID in org.apache.flink.runtime.resourcemanager
Methods in org.apache.flink.runtime.resourcemanager with parameters of type SlotID Modifier and Type Method Description voidResourceManager. notifySlotAvailable(InstanceID instanceID, SlotID slotId, AllocationID allocationId)voidResourceManagerGateway. notifySlotAvailable(InstanceID instanceId, SlotID slotID, AllocationID oldAllocationId)Sent by the TaskExecutor to notify the ResourceManager that a slot has become available. -
Uses of SlotID in org.apache.flink.runtime.resourcemanager.slotmanager
Methods in org.apache.flink.runtime.resourcemanager.slotmanager that return SlotID Modifier and Type Method Description SlotIDFineGrainedTaskManagerSlot. getSlotId()SlotIDTaskManagerSlotInformation. getSlotId()Methods in org.apache.flink.runtime.resourcemanager.slotmanager that return types with arguments of type SlotID Modifier and Type Method Description Iterable<SlotID>TaskManagerRegistration. getSlots()Methods in org.apache.flink.runtime.resourcemanager.slotmanager with parameters of type SlotID Modifier and Type Method Description booleanTaskManagerRegistration. containsSlot(SlotID slotId)voidFineGrainedSlotManager. freeSlot(SlotID slotId, AllocationID allocationId)Free the given slot from the given allocation.voidSlotManager. freeSlot(SlotID slotId, AllocationID allocationId)Free the given slot from the given allocation.Constructor parameters in org.apache.flink.runtime.resourcemanager.slotmanager with type arguments of type SlotID Constructor Description TaskManagerRegistration(TaskExecutorConnection taskManagerConnection, Collection<SlotID> slots, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile) -
Uses of SlotID in org.apache.flink.runtime.taskexecutor
Methods in org.apache.flink.runtime.taskexecutor that return SlotID Modifier and Type Method Description SlotIDSlotStatus. getSlotID()Get the unique identification of this slot.Methods in org.apache.flink.runtime.taskexecutor with parameters of type SlotID Modifier and Type Method Description CompletableFuture<Acknowledge>TaskExecutor. requestSlot(SlotID slotId, org.apache.flink.api.common.JobID jobId, AllocationID allocationId, ResourceProfile resourceProfile, String targetAddress, ResourceManagerId resourceManagerId, org.apache.flink.api.common.time.Time timeout)CompletableFuture<Acknowledge>TaskExecutorGateway. requestSlot(SlotID slotId, org.apache.flink.api.common.JobID jobId, AllocationID allocationId, ResourceProfile resourceProfile, String targetAddress, ResourceManagerId resourceManagerId, org.apache.flink.api.common.time.Time timeout)Requests a slot from the TaskManager.CompletableFuture<Acknowledge>TaskExecutorGatewayDecoratorBase. requestSlot(SlotID slotId, org.apache.flink.api.common.JobID jobId, AllocationID allocationId, ResourceProfile resourceProfile, String targetAddress, ResourceManagerId resourceManagerId, org.apache.flink.api.common.time.Time timeout)Constructors in org.apache.flink.runtime.taskexecutor with parameters of type SlotID Constructor Description SlotStatus(SlotID slotID, ResourceProfile resourceProfile)SlotStatus(SlotID slotID, ResourceProfile resourceProfile, org.apache.flink.api.common.JobID jobID, AllocationID allocationID) -
Uses of SlotID in org.apache.flink.runtime.taskexecutor.slot
Methods in org.apache.flink.runtime.taskexecutor.slot that return SlotID Modifier and Type Method Description SlotIDSlotAllocationSnapshot. getSlotID()Constructors in org.apache.flink.runtime.taskexecutor.slot with parameters of type SlotID Constructor Description SlotAllocationSnapshot(SlotID slotID, org.apache.flink.api.common.JobID jobId, String jobTargetAddress, AllocationID allocationId, ResourceProfile resourceProfile)
-