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

Class TaskManagerRegistration

java.lang.Object

org.apache.flink.runtime.resourcemanager.slotmanager.TaskManagerRegistration

public class TaskManagerRegistration
extends Object

Constructor Summary

Constructors

Constructor	Description
TaskManagerRegistration(TaskExecutorConnection taskManagerConnection, Collection<SlotID> slots, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile)

Method Summary

Modifier and Type	Method	Description
boolean	containsSlot(SlotID slotId)
void	freeSlot()
ResourceProfile	getDefaultSlotResourceProfile()
long	getIdleSince()
InstanceID	getInstanceId()
int	getNumberFreeSlots()
int	getNumberRegisteredSlots()
Iterable<SlotID>	getSlots()
TaskExecutorConnection	getTaskManagerConnection()
ResourceProfile	getTotalResource()
boolean	isIdle()
void	markUsed()
void	occupySlot()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskManagerRegistration

public TaskManagerRegistration(TaskExecutorConnection taskManagerConnection,
                               Collection<SlotID> slots,
                               ResourceProfile totalResourceProfile,
                               ResourceProfile defaultSlotResourceProfile)

Method Detail

getTaskManagerConnection

public TaskExecutorConnection getTaskManagerConnection()

getInstanceId

public InstanceID getInstanceId()

getNumberRegisteredSlots

public int getNumberRegisteredSlots()

getNumberFreeSlots

public int getNumberFreeSlots()

getDefaultSlotResourceProfile

public ResourceProfile getDefaultSlotResourceProfile()

getTotalResource

public ResourceProfile getTotalResource()

freeSlot

public void freeSlot()

occupySlot

public void occupySlot()

getSlots

public Iterable<SlotID> getSlots()

getIdleSince

public long getIdleSince()

isIdle

public boolean isIdle()

markUsed

public void markUsed()

containsSlot

public boolean containsSlot(SlotID slotId)