org.apache.flink.yarn

Interface YarnResourceManagerClientFactory

All Known Implementing Classes:

DefaultYarnResourceManagerClientFactory

public interface YarnResourceManagerClientFactory

Factory interface for AMRMClientAsync.

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.yarn.client.api.async.AMRMClientAsync<org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest>	createResourceManagerClient(int yarnHeartbeatIntervalMillis, org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler callbackHandler) Create YARN ResourceManager client with the given callback handler.

Method Detail

createResourceManagerClient

org.apache.hadoop.yarn.client.api.async.AMRMClientAsync<org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest> createResourceManagerClient(int yarnHeartbeatIntervalMillis,
                                                                                                                                                   org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler callbackHandler)

Create YARN ResourceManager client with the given callback handler.

Parameters:

yarnHeartbeatIntervalMillis - heartbeat interval between the client and the YARN ResourceManager.

callbackHandler - which handles the events from YARN ResourceManager.

Returns:

an AMRMClientAsync instance.