org.apache.flink.runtime.jobmaster

Interface SlotContext

All Known Implementing Classes:

SimpleSlotContext

public interface SlotContext

Interface for the context of a LogicalSlot. This context contains information about the underlying allocated slot and how to communicate with the TaskManager on which it was allocated.

Method Summary

Modifier and Type	Method and Description
AllocationID	getAllocationId() Gets the id under which the slot has been allocated on the TaskManager.
int	getPhysicalSlotNumber() Gets the number of the slot.
TaskManagerGateway	getTaskManagerGateway() Gets the actor gateway that can be used to send messages to the TaskManager.
TaskManagerLocation	getTaskManagerLocation() Gets the location info of the TaskManager that offers this slot.

Method Detail

getAllocationId

AllocationID getAllocationId()

Gets the id under which the slot has been allocated on the TaskManager. This id uniquely identifies the physical slot.

Returns:

The id under which the slot has been allocated on the TaskManager

getTaskManagerLocation

TaskManagerLocation getTaskManagerLocation()

Gets the location info of the TaskManager that offers this slot.

Returns:

The location info of the TaskManager that offers this slot

getPhysicalSlotNumber

int getPhysicalSlotNumber()

Gets the number of the slot.

Returns:

The number of the slot on the TaskManager.

getTaskManagerGateway

TaskManagerGateway getTaskManagerGateway()

Gets the actor gateway that can be used to send messages to the TaskManager.

This method should be removed once the new interface-based RPC abstraction is in place

Returns:

The gateway that can be used to send messages to the TaskManager.