org.apache.flink.runtime.resourcemanager.slotmanager

Interface TaskManagerInfo

All Known Implementing Classes:

FineGrainedTaskManagerRegistration

public interface TaskManagerInfo

Information of a TaskManager needed in SlotManager.

Method Summary

Modifier and Type	Method and Description
Map<AllocationID,TaskManagerSlotInformation>	getAllocatedSlots() Get allocated slots information.
ResourceProfile	getAvailableResource() Get the available resource.
int	getDefaultNumSlots() Get the default number of slots.
ResourceProfile	getDefaultSlotResourceProfile() Get the default slot resource profile.
long	getIdleSince() Get the timestamp when the last time becoming idle.
InstanceID	getInstanceId() Get the instanceId of this task manager.
TaskExecutorConnection	getTaskExecutorConnection() Get the taskExecutorConnection.
ResourceProfile	getTotalResource() Get the total resource.
boolean	isIdle() Check whether this task manager is idle.

Method Detail

getInstanceId

InstanceID getInstanceId()

Get the instanceId of this task manager.

Returns:

the instanceId

getTaskExecutorConnection

TaskExecutorConnection getTaskExecutorConnection()

Get the taskExecutorConnection.

Returns:

the taskExecutorConnection

getAllocatedSlots

Map<AllocationID,TaskManagerSlotInformation> getAllocatedSlots()

Get allocated slots information.

Returns:

allocated slots information mapped by its allocationId

getAvailableResource

ResourceProfile getAvailableResource()

Get the available resource.

Returns:

the available resource

getTotalResource

ResourceProfile getTotalResource()

Get the total resource.

Returns:

the total resource

getDefaultSlotResourceProfile

ResourceProfile getDefaultSlotResourceProfile()

Get the default slot resource profile.

Returns:

the default slot resource profile

getDefaultNumSlots

int getDefaultNumSlots()

Get the default number of slots.

Returns:

the default number of slots

getIdleSince

long getIdleSince()

Get the timestamp when the last time becoming idle.

Returns:

the timestamp when the last time becoming idle

isIdle

boolean isIdle()

Check whether this task manager is idle.

Returns:

whether this task manager is idle