org.apache.tez.client

Class TezYarnClient

java.lang.Object

org.apache.tez.client.FrameworkClient

org.apache.tez.client.TezYarnClient

@InterfaceAudience.Private
public class TezYarnClient
extends FrameworkClient

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TezYarnClient(org.apache.hadoop.yarn.client.api.YarnClient yarnClient)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.yarn.client.api.YarnClientApplication	createApplication()
org.apache.hadoop.yarn.api.records.ApplicationReport	getApplicationReport(org.apache.hadoop.yarn.api.records.ApplicationId appId)
void	init(TezConfiguration tezConf, org.apache.hadoop.yarn.conf.YarnConfiguration yarnConf) Initialize the framework client.
void	killApplication(org.apache.hadoop.yarn.api.records.ApplicationId appId)
void	start()
void	stop()
org.apache.hadoop.yarn.api.records.ApplicationId	submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext appSubmissionContext)

Methods inherited from class org.apache.tez.client.FrameworkClient

createFrameworkClient

Methods inherited from class java.lang.Object

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

Constructor Detail

TezYarnClient

protected TezYarnClient(org.apache.hadoop.yarn.client.api.YarnClient yarnClient)

Method Detail

init

public void init(TezConfiguration tezConf,
        org.apache.hadoop.yarn.conf.YarnConfiguration yarnConf)

Description copied from class: FrameworkClient

Initialize the framework client.

The actual implementation of FramworkClient may modify the configuration instances that are passed in to configure required functionality

Specified by:

init in class FrameworkClient

Parameters:

tezConf - the TezConfiguration instance being used by the cluster

yarnConf - the YarnConfiguration instance being used by the cluster

start

public void start()

Specified by:

start in class FrameworkClient

stop

public void stop()

Specified by:

stop in class FrameworkClient

close

public final void close()
                 throws IOException

Specified by:

close in class FrameworkClient

Throws:

IOException

createApplication

public org.apache.hadoop.yarn.client.api.YarnClientApplication createApplication()
                                                                          throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                 IOException

Specified by:

createApplication in class FrameworkClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

submitApplication

public org.apache.hadoop.yarn.api.records.ApplicationId submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext appSubmissionContext)
                                                                   throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                          IOException,
                                                                          TezException

Specified by:

submitApplication in class FrameworkClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

TezException

killApplication

public void killApplication(org.apache.hadoop.yarn.api.records.ApplicationId appId)
                     throws org.apache.hadoop.yarn.exceptions.YarnException,
                            IOException

Specified by:

killApplication in class FrameworkClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getApplicationReport

public org.apache.hadoop.yarn.api.records.ApplicationReport getApplicationReport(org.apache.hadoop.yarn.api.records.ApplicationId appId)
                                                                          throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                 IOException

Specified by:

getApplicationReport in class FrameworkClient

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException