org.apache.flink.runtime.resourcemanager

Interface ResourceManagerServices

public interface ResourceManagerServices

Interface which provides access to services of the ResourceManager.

Method Summary

Modifier and Type	Method and Description
void	allocateResource(ResourceProfile resourceProfile) Allocates a resource according to the resource profile.
Executor	getAsyncExecutor() Gets the async executor which executes outside of the main thread of the ResourceManager
UUID	getLeaderID() Gets the current leader id assigned at the ResourceManager.
Executor	getMainThreadExecutor() Gets the executor which executes in the main thread of the ResourceManager

Method Detail

getLeaderID

UUID getLeaderID()

Gets the current leader id assigned at the ResourceManager.

allocateResource

void allocateResource(ResourceProfile resourceProfile)

Allocates a resource according to the resource profile.

getAsyncExecutor

Executor getAsyncExecutor()

Gets the async executor which executes outside of the main thread of the ResourceManager

getMainThreadExecutor

Executor getMainThreadExecutor()

Gets the executor which executes in the main thread of the ResourceManager