org.apache.flink.runtime.resourcemanager.slotmanager

Interface ClusterResourceStatisticsProvider

public interface ClusterResourceStatisticsProvider

Provides statistics of cluster resources.

Method Summary

Modifier and Type	Method and Description
ResourceProfile	getFreeResource() Get profile of total free resources.
ResourceProfile	getFreeResourceOf(InstanceID instanceId) Get profile of free resources from the TaskManager with the given instance id.
int	getNumberFreeSlots() Get total number of free slots.
int	getNumberFreeSlotsOf(InstanceID instanceId) Get number of free slots from the TaskManager with the given instance id.
int	getNumberRegisteredSlots() Get total number of registered slots.
int	getNumberRegisteredSlotsOf(InstanceID instanceId) Get number of registered slots from the TaskManager with the given instance id.
ResourceProfile	getPendingResource() Get profile of total pending resources.
ResourceProfile	getRegisteredResource() Get profile of total registered resources.
ResourceProfile	getRegisteredResourceOf(InstanceID instanceId) Get profile of registered resources from the TaskManager with the given instance id.

Method Detail

getNumberRegisteredSlots

int getNumberRegisteredSlots()

Get total number of registered slots.

getNumberRegisteredSlotsOf

int getNumberRegisteredSlotsOf(InstanceID instanceId)

Get number of registered slots from the TaskManager with the given instance id.

getNumberFreeSlots

int getNumberFreeSlots()

Get total number of free slots.

getNumberFreeSlotsOf

int getNumberFreeSlotsOf(InstanceID instanceId)

Get number of free slots from the TaskManager with the given instance id.

getRegisteredResource

ResourceProfile getRegisteredResource()

Get profile of total registered resources.

getRegisteredResourceOf

ResourceProfile getRegisteredResourceOf(InstanceID instanceId)

Get profile of registered resources from the TaskManager with the given instance id.

getFreeResource

ResourceProfile getFreeResource()

Get profile of total free resources.

getFreeResourceOf

ResourceProfile getFreeResourceOf(InstanceID instanceId)

Get profile of free resources from the TaskManager with the given instance id.

getPendingResource

ResourceProfile getPendingResource()

Get profile of total pending resources.