Package org.apache.drill.yarn.core

Class YarnRMClient

java.lang.Object

org.apache.drill.yarn.core.YarnRMClient

public class YarnRMClient
extends Object

YARN resource manager client implementation for Drill. Provides a wrapper around the YARN client interface to the Resource Manager. Used by the client app to start the Drill application master.

Based on simple-yarn-app

Constructor Summary

Constructors

Constructor	Description
YarnRMClient()
YarnRMClient(org.apache.hadoop.yarn.api.records.ApplicationId appId)
YarnRMClient(org.apache.hadoop.yarn.conf.YarnConfiguration conf)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse	createAppMaster()
org.apache.hadoop.security.token.Token<org.apache.hadoop.yarn.security.AMRMTokenIdentifier>	getAMRMToken()
org.apache.hadoop.yarn.api.records.ApplicationId	getAppId()
org.apache.hadoop.yarn.api.records.ApplicationReport	getAppReport()
String[]	getYarnAppClassPath()	Return standard class path entries from the YARN application class path.
void	killApplication()
void	submitAppMaster(AppSpec spec)
void	waitForCompletion()	Wait for the application to enter one of the completion states.
org.apache.hadoop.yarn.api.records.ApplicationAttemptId	waitForStart()	Waits for the application to start.

Methods inherited from class java.lang.Object

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

Constructor Details

YarnRMClient

public YarnRMClient()

YarnRMClient

public YarnRMClient(org.apache.hadoop.yarn.api.records.ApplicationId appId)

YarnRMClient

public YarnRMClient(org.apache.hadoop.yarn.conf.YarnConfiguration conf)

Method Details

createAppMaster

public org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse createAppMaster()
                                                                                     throws YarnClientException

Throws:

YarnClientException

submitAppMaster

public void submitAppMaster(AppSpec spec)
                     throws YarnClientException

Throws:

YarnClientException

getAppId

public org.apache.hadoop.yarn.api.records.ApplicationId getAppId()

getAppReport

public org.apache.hadoop.yarn.api.records.ApplicationReport getAppReport()
                                                                  throws YarnClientException

Throws:

YarnClientException

waitForStart

public org.apache.hadoop.yarn.api.records.ApplicationAttemptId waitForStart()
                                                                     throws YarnClientException

Waits for the application to start. This version is somewhat informal, the intended use is when debugging unmanaged applications.

Throws:

YarnClientException

waitForCompletion

public void waitForCompletion()
                       throws YarnClientException

Wait for the application to enter one of the completion states. This is an informal implementation useful for testing.

Throws:

YarnClientException

getAMRMToken

public org.apache.hadoop.security.token.Token<org.apache.hadoop.yarn.security.AMRMTokenIdentifier> getAMRMToken()
                                                                                                         throws YarnClientException

Throws:

YarnClientException

getYarnAppClassPath

public String[] getYarnAppClassPath()

Return standard class path entries from the YARN application class path.

killApplication

public void killApplication()
                     throws YarnClientException

Throws:

YarnClientException