org.apache.flink.yarn

Class DefaultYarnNodeManagerClientFactory

java.lang.Object

org.apache.flink.yarn.DefaultYarnNodeManagerClientFactory

All Implemented Interfaces:

YarnNodeManagerClientFactory

public class DefaultYarnNodeManagerClientFactory
extends Object
implements YarnNodeManagerClientFactory

Default implementation of YarnNodeManagerClientFactory.

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.yarn.client.api.async.NMClientAsync	createNodeManagerClient(org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler callbackHandler) Create YARN NodeManager client with the given callback handler.
static YarnNodeManagerClientFactory	getInstance()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getInstance

public static YarnNodeManagerClientFactory getInstance()

createNodeManagerClient

public org.apache.hadoop.yarn.client.api.async.NMClientAsync createNodeManagerClient(org.apache.hadoop.yarn.client.api.async.NMClientAsync.CallbackHandler callbackHandler)

Description copied from interface: YarnNodeManagerClientFactory

Create YARN NodeManager client with the given callback handler.

Specified by:

createNodeManagerClient in interface YarnNodeManagerClientFactory

Parameters:

callbackHandler - which handles the events from YARN NodeManager.

Returns:

a NMClientAsync instance.