org.apache.flink.runtime.jobmaster.slotpool

Class SlotSharingManager.MultiTaskSlot

java.lang.Object

org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager.TaskSlot

org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager.MultiTaskSlot

All Implemented Interfaces:

PhysicalSlot.Payload

Enclosing class:

SlotSharingManager

public final class SlotSharingManager.MultiTaskSlot
extends SlotSharingManager.TaskSlot
implements PhysicalSlot.Payload

SlotSharingManager.TaskSlot implementation which can have multiple other task slots assigned as children.

Method Summary

Modifier and Type	Method and Description
boolean	contains(AbstractID groupId) Checks whether this slot or any of its children contains the given groupId.
ResourceProfile	getReservedResources() Gets the total reserved resources of the slot and its descendants.
void	release(Throwable cause) Release the task slot.
String	toString()
boolean	willOccupySlotIndefinitely() Returns whether the payload will occupy a physical slot indefinitely.

Methods inherited from class org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager.TaskSlot

getGroupId, getSlotRequestId

Methods inherited from class java.lang.Object

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

Method Detail

contains

public boolean contains(AbstractID groupId)

Checks whether this slot or any of its children contains the given groupId.

Overrides:

contains in class SlotSharingManager.TaskSlot

Parameters:

groupId - which to check whether it is contained

Returns:

true if this or any of its children contains the given groupId, otherwise false

release

public void release(Throwable cause)

Description copied from class: SlotSharingManager.TaskSlot

Release the task slot.

Specified by:

release in interface PhysicalSlot.Payload

Specified by:

release in class SlotSharingManager.TaskSlot

Parameters:

cause - for the release

willOccupySlotIndefinitely

public boolean willOccupySlotIndefinitely()

Description copied from interface: PhysicalSlot.Payload

Returns whether the payload will occupy a physical slot indefinitely.

Specified by:

willOccupySlotIndefinitely in interface PhysicalSlot.Payload

Returns:

true if the payload will occupy a physical slot indefinitely, otherwise false

getReservedResources

public ResourceProfile getReservedResources()

Description copied from class: SlotSharingManager.TaskSlot

Gets the total reserved resources of the slot and its descendants.

Specified by:

getReservedResources in class SlotSharingManager.TaskSlot

toString

public String toString()

Overrides:

toString in class Object