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 and Description
TaskManagerRegistration(TaskExecutorConnection taskManagerConnection, Collection<SlotID> slots)

Method Summary

Modifier and Type	Method and Description
boolean	containsSlot(SlotID slotId)
void	freeSlot()
long	getIdleSince()
InstanceID	getInstanceId()
int	getNumberFreeSlots()
int	getNumberRegisteredSlots()
Iterable<SlotID>	getSlots()
TaskExecutorConnection	getTaskManagerConnection()
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)

Method Detail

getTaskManagerConnection

public TaskExecutorConnection getTaskManagerConnection()

getInstanceId

public InstanceID getInstanceId()

getNumberRegisteredSlots

public int getNumberRegisteredSlots()

getNumberFreeSlots

public int getNumberFreeSlots()

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)