Uses of Class
org.apache.flink.runtime.instance.InstanceID

Packages that use InstanceID

Package	Description
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.registration
org.apache.flink.runtime.resourcemanager.slotmanager
org.apache.flink.runtime.taskexecutor

Uses of InstanceID in org.apache.flink.runtime.resourcemanager

Methods in org.apache.flink.runtime.resourcemanager that return types with arguments of type InstanceID

Modifier and Type	Method	Description
Optional<InstanceID>	ResourceManager.getInstanceIdByResourceId(ResourceID resourceID)

Methods in org.apache.flink.runtime.resourcemanager with parameters of type InstanceID

Modifier and Type	Method	Description
protected WorkerType	ResourceManager.getWorkerByInstanceId(InstanceID instanceId)
void	ResourceManager.notifySlotAvailable(InstanceID instanceID, SlotID slotId, AllocationID allocationId)
void	ResourceManagerGateway.notifySlotAvailable(InstanceID instanceId, SlotID slotID, AllocationID oldAllocationId)	Sent by the TaskExecutor to notify the ResourceManager that a slot has become available.
CompletableFuture<Acknowledge>	ResourceManager.sendSlotReport(ResourceID taskManagerResourceId, InstanceID taskManagerRegistrationId, SlotReport slotReport, org.apache.flink.api.common.time.Time timeout)
CompletableFuture<Acknowledge>	ResourceManagerGateway.sendSlotReport(ResourceID taskManagerResourceId, InstanceID taskManagerRegistrationId, SlotReport slotReport, org.apache.flink.api.common.time.Time timeout)	Sends the given SlotReport to the ResourceManager.

Uses of InstanceID in org.apache.flink.runtime.resourcemanager.registration

Methods in org.apache.flink.runtime.resourcemanager.registration that return InstanceID

Modifier and Type	Method	Description
InstanceID	TaskExecutorConnection.getInstanceID()

Uses of InstanceID in org.apache.flink.runtime.resourcemanager.slotmanager

Methods in org.apache.flink.runtime.resourcemanager.slotmanager that return InstanceID

Modifier and Type	Method	Description
InstanceID	FineGrainedTaskManagerRegistration.getInstanceId()
InstanceID	FineGrainedTaskManagerSlot.getInstanceId()
InstanceID	TaskManagerInfo.getInstanceId()	Get the instanceId of this task manager.
InstanceID	TaskManagerRegistration.getInstanceId()
InstanceID	TaskManagerSlotInformation.getInstanceId()

Methods in org.apache.flink.runtime.resourcemanager.slotmanager that return types with arguments of type InstanceID

Modifier and Type	Method	Description
Map<org.apache.flink.api.common.JobID,Map<InstanceID,ResourceCounter>>	ResourceAllocationResult.getAllocationsOnRegisteredResources()
Map<InstanceID,WorkerResourceSpec>	FineGrainedTaskManagerTracker.getUnWantedTaskManager()
Collection<InstanceID>	ResourceDeclaration.getUnwantedWorkers()

Methods in org.apache.flink.runtime.resourcemanager.slotmanager with parameters of type InstanceID

Modifier and Type	Method	Description
ResourceAllocationResult.Builder	ResourceAllocationResult.Builder.addAllocationOnRegisteredResource(org.apache.flink.api.common.JobID jobId, InstanceID instanceId, ResourceProfile resourceProfile)
void	FineGrainedTaskManagerTracker.addUnWantedTaskManager(InstanceID instanceId)
CompletableFuture<Void>	DefaultSlotStatusSyncer.allocateSlot(InstanceID instanceId, org.apache.flink.api.common.JobID jobId, String targetAddress, ResourceProfile resourceProfile)
CompletableFuture<Void>	SlotStatusSyncer.allocateSlot(InstanceID instanceId, org.apache.flink.api.common.JobID jobId, String targetAddress, ResourceProfile resourceProfile)	Allocate a slot from the task manager.
Collection<SlotInfo>	DeclarativeSlotManager.getAllocatedSlotsOf(InstanceID instanceID)
Collection<SlotInfo>	FineGrainedSlotManager.getAllocatedSlotsOf(InstanceID instanceID)
Collection<SlotInfo>	SlotManager.getAllocatedSlotsOf(InstanceID instanceID)
ResourceProfile	ClusterResourceStatisticsProvider.getFreeResourceOf(InstanceID instanceId)	Get profile of free resources from the TaskManager with the given instance id.
ResourceProfile	DeclarativeSlotManager.getFreeResourceOf(InstanceID instanceID)
ResourceProfile	FineGrainedSlotManager.getFreeResourceOf(InstanceID instanceID)
ResourceProfile	FineGrainedTaskManagerTracker.getFreeResourceOf(InstanceID instanceId)
ResourceProfile	SlotManager.getFreeResourceOf(InstanceID instanceID)
int	ClusterResourceStatisticsProvider.getNumberFreeSlotsOf(InstanceID instanceId)	Get number of free slots from the TaskManager with the given instance id.
int	DeclarativeSlotManager.getNumberFreeSlotsOf(InstanceID instanceId)
int	FineGrainedSlotManager.getNumberFreeSlotsOf(InstanceID instanceId)
int	FineGrainedTaskManagerTracker.getNumberFreeSlotsOf(InstanceID instanceId)
int	SlotManager.getNumberFreeSlotsOf(InstanceID instanceId)
int	ClusterResourceStatisticsProvider.getNumberRegisteredSlotsOf(InstanceID instanceId)	Get number of registered slots from the TaskManager with the given instance id.
int	DeclarativeSlotManager.getNumberRegisteredSlotsOf(InstanceID instanceId)
int	FineGrainedSlotManager.getNumberRegisteredSlotsOf(InstanceID instanceId)
int	FineGrainedTaskManagerTracker.getNumberRegisteredSlotsOf(InstanceID instanceId)
int	SlotManager.getNumberRegisteredSlotsOf(InstanceID instanceId)
ResourceProfile	ClusterResourceStatisticsProvider.getRegisteredResourceOf(InstanceID instanceId)	Get profile of registered resources from the TaskManager with the given instance id.
ResourceProfile	DeclarativeSlotManager.getRegisteredResourceOf(InstanceID instanceID)
ResourceProfile	FineGrainedSlotManager.getRegisteredResourceOf(InstanceID instanceID)
ResourceProfile	FineGrainedTaskManagerTracker.getRegisteredResourceOf(InstanceID instanceId)
ResourceProfile	SlotManager.getRegisteredResourceOf(InstanceID instanceID)
Optional<TaskManagerInfo>	FineGrainedTaskManagerTracker.getRegisteredTaskManager(InstanceID instanceId)
long	FineGrainedSlotManager.getTaskManagerIdleSince(InstanceID instanceId)
void	FineGrainedTaskManagerTracker.notifySlotStatus(AllocationID allocationId, org.apache.flink.api.common.JobID jobId, InstanceID instanceId, ResourceProfile resourceProfile, org.apache.flink.runtime.resourcemanager.slotmanager.SlotState slotState)
void	FineGrainedTaskManagerTracker.removeTaskManager(InstanceID instanceId)
boolean	DeclarativeSlotManager.reportSlotStatus(InstanceID instanceId, SlotReport slotReport)	Reports the current slot allocations for a task manager identified by the given instance id.
boolean	DefaultSlotStatusSyncer.reportSlotStatus(InstanceID instanceId, SlotReport slotReport)
boolean	FineGrainedSlotManager.reportSlotStatus(InstanceID instanceId, SlotReport slotReport)	Reports the current slot allocations for a task manager identified by the given instance id.
boolean	SlotManager.reportSlotStatus(InstanceID instanceId, SlotReport slotReport)	Reports the current slot allocations for a task manager identified by the given instance id.
boolean	SlotStatusSyncer.reportSlotStatus(InstanceID instanceId, SlotReport slotReport)	Reconcile the slot status with the slot report.
boolean	DeclarativeSlotManager.unregisterTaskManager(InstanceID instanceId, Exception cause)
boolean	FineGrainedSlotManager.unregisterTaskManager(InstanceID instanceId, Exception cause)
boolean	SlotManager.unregisterTaskManager(InstanceID instanceId, Exception cause)	Unregisters the task manager identified by the given instance id and its associated slots from the slot manager.

Method parameters in org.apache.flink.runtime.resourcemanager.slotmanager with type arguments of type InstanceID

Modifier and Type	Method	Description
<T extends TaskManagerSlotInformation> Optional<T>	AnyMatchingSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile, Collection<T> freeSlots, java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup)
<T extends TaskManagerSlotInformation> Optional<T>	LeastUtilizationSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile, Collection<T> freeSlots, java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup)
<T extends TaskManagerSlotInformation> Optional<T>	SlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile, Collection<T> freeSlots, java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup)	Finds a matching slot for the requested ResourceProfile given the collection of free slots and the total number of slots per TaskExecutor.

Constructor parameters in org.apache.flink.runtime.resourcemanager.slotmanager with type arguments of type InstanceID

Constructor	Description
ResourceDeclaration(WorkerResourceSpec spec, int numNeeded, Collection<InstanceID> unwantedWorkers)

Uses of InstanceID in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor that return InstanceID

Modifier and Type	Method	Description
InstanceID	TaskExecutorRegistrationSuccess.getRegistrationId()	Gets the ID that the ResourceManager assigned the registration.

Constructors in org.apache.flink.runtime.taskexecutor with parameters of type InstanceID

Constructor	Description
TaskExecutorRegistrationSuccess(InstanceID registrationId, ResourceID resourceManagerResourceId, ClusterInformation clusterInformation, byte[] initialTokens)	Create a new TaskExecutorRegistrationSuccess message.