org.apache.flink.runtime.jobmaster.slotpool

Interface PhysicalSlot

All Superinterfaces:

SlotContext, SlotInfo

public interface PhysicalSlot
extends SlotContext

The context of an AllocatedSlot. This represent an interface to classes outside the slot pool to interact with allocated slots.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	PhysicalSlot.Payload Payload which can be assigned to an AllocatedSlot.

Method Summary

Modifier and Type	Method and Description
boolean	tryAssignPayload(PhysicalSlot.Payload payload) Tries to assign the given payload to this allocated slot.

Methods inherited from interface org.apache.flink.runtime.jobmaster.SlotContext

getTaskManagerGateway

Methods inherited from interface org.apache.flink.runtime.jobmaster.SlotInfo

getAllocationId, getPhysicalSlotNumber, getResourceProfile, getTaskManagerLocation, willBeOccupiedIndefinitely

Method Detail

tryAssignPayload

boolean tryAssignPayload(PhysicalSlot.Payload payload)

Tries to assign the given payload to this allocated slot. This only works if there has not been another payload assigned to this slot.

Parameters:

payload - to assign to this slot

Returns:

true if the payload could be assigned, otherwise false