Package org.apache.flink.runtime.resourcemanager.slotmanager

Class DefaultSlotTracker

java.lang.Object

org.apache.flink.runtime.resourcemanager.slotmanager.DefaultSlotTracker

public class DefaultSlotTracker
extends Object

Default SlotTracker implementation.

Constructor Summary

Constructors

Constructor	Description
DefaultSlotTracker()

Method Summary

Modifier and Type	Method	Description
void	addSlot(SlotID slotId, ResourceProfile resourceProfile, TaskExecutorConnection taskManagerConnection, org.apache.flink.api.common.JobID assignedJob)
Collection<TaskManagerSlotInformation>	getFreeSlots()
Collection<TaskExecutorConnection>	getTaskExecutorsWithAllocatedSlotsForJob(org.apache.flink.api.common.JobID jobId)
void	notifyAllocationComplete(SlotID slotId, org.apache.flink.api.common.JobID jobId)
void	notifyAllocationStart(SlotID slotId, org.apache.flink.api.common.JobID jobId)
void	notifyFree(SlotID slotId)
boolean	notifySlotStatus(Iterable<SlotStatus> slotStatuses)
void	registerSlotStatusUpdateListener(org.apache.flink.runtime.resourcemanager.slotmanager.SlotStatusUpdateListener slotStatusUpdateListener)
void	removeSlots(Iterable<SlotID> slotsToRemove)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSlotTracker

public DefaultSlotTracker()

Method Detail

registerSlotStatusUpdateListener

public void registerSlotStatusUpdateListener(org.apache.flink.runtime.resourcemanager.slotmanager.SlotStatusUpdateListener slotStatusUpdateListener)

addSlot

public void addSlot(SlotID slotId,
                    ResourceProfile resourceProfile,
                    TaskExecutorConnection taskManagerConnection,
                    @Nullable
                    org.apache.flink.api.common.JobID assignedJob)

removeSlots

public void removeSlots(Iterable<SlotID> slotsToRemove)

notifyFree

public void notifyFree(SlotID slotId)

notifyAllocationStart

public void notifyAllocationStart(SlotID slotId,
                                  org.apache.flink.api.common.JobID jobId)

notifyAllocationComplete

public void notifyAllocationComplete(SlotID slotId,
                                     org.apache.flink.api.common.JobID jobId)

notifySlotStatus

public boolean notifySlotStatus(Iterable<SlotStatus> slotStatuses)

getFreeSlots

public Collection<TaskManagerSlotInformation> getFreeSlots()

getTaskExecutorsWithAllocatedSlotsForJob

public Collection<TaskExecutorConnection> getTaskExecutorsWithAllocatedSlotsForJob(org.apache.flink.api.common.JobID jobId)