org.apache.flink.runtime.resourcemanager.slotmanager

Interface ResourceTracker

All Known Implementing Classes:

DefaultResourceTracker

public interface ResourceTracker

Tracks for each job how many resource are required/acquired.

Method Summary

Modifier and Type	Method and Description
void	clear() Removes all state from the tracker.
Collection<ResourceRequirement>	getAcquiredResources(JobID jobId) Returns a collection of ResourceRequirements that describe which resources have been assigned to a job.
Map<JobID,Collection<ResourceRequirement>>	getMissingResources() Returns a collection of ResourceRequirements that describe which resources the corresponding job is missing.
boolean	isRequirementEmpty(JobID jobId) Returns whether the ResourceRequirement of the given job is empty.
void	notifyAcquiredResource(JobID jobId, ResourceProfile resourceProfile) Notifies the tracker about the acquisition of a resource with the given resource profile, for the given job.
void	notifyLostResource(JobID jobId, ResourceProfile resourceProfile) Notifies the tracker about the loss of a resource with the given resource profile, for the given job.
void	notifyResourceRequirements(JobID jobId, Collection<ResourceRequirement> resourceRequirements) Notifies the tracker about a new or updated ResourceRequirements.

Method Detail

notifyResourceRequirements

void notifyResourceRequirements(JobID jobId,
                                Collection<ResourceRequirement> resourceRequirements)

Notifies the tracker about a new or updated ResourceRequirements.

Parameters:

jobId - the job that the resource requirements belongs to

resourceRequirements - new resource requirements

notifyAcquiredResource

void notifyAcquiredResource(JobID jobId,
                            ResourceProfile resourceProfile)

Notifies the tracker about the acquisition of a resource with the given resource profile, for the given job.

Parameters:

jobId - the job that acquired the resource

resourceProfile - profile of the resource

notifyLostResource

void notifyLostResource(JobID jobId,
                        ResourceProfile resourceProfile)

Notifies the tracker about the loss of a resource with the given resource profile, for the given job.

Parameters:

jobId - the job that lost the resource

resourceProfile - profile of the resource

getMissingResources

Map<JobID,Collection<ResourceRequirement>> getMissingResources()

Returns a collection of ResourceRequirements that describe which resources the corresponding job is missing.

Returns:

missing resources for each jobs

getAcquiredResources

Collection<ResourceRequirement> getAcquiredResources(JobID jobId)

Returns a collection of ResourceRequirements that describe which resources have been assigned to a job.

Parameters:

jobId - job ID

Returns:

required/exceeding resources for each jobs

isRequirementEmpty

boolean isRequirementEmpty(JobID jobId)

Returns whether the ResourceRequirement of the given job is empty.

Parameters:

jobId - job ID

Returns:

true if the ResourceRequirement of the given job is empty

clear

void clear()

Removes all state from the tracker.