org.apache.tez.client

Class MRTezClient

java.lang.Object

org.apache.tez.client.TezClient

org.apache.tez.client.MRTezClient

@InterfaceAudience.Private
public class MRTezClient
extends org.apache.tez.client.TezClient

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.tez.client.TezClient

org.apache.tez.client.TezClient.TezClientBuilder

Field Summary

Fields inherited from class org.apache.tez.client.TezClient

DAG

Constructor Summary

Constructors

Constructor and Description
MRTezClient(String name, org.apache.tez.dag.api.TezConfiguration tezConf, boolean isSession, Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localResources, org.apache.hadoop.security.Credentials credentials)

Method Summary

Methods

Modifier and Type	Method and Description
static MRDAGClient	getDAGClient(org.apache.hadoop.yarn.api.records.ApplicationId appId, org.apache.tez.dag.api.TezConfiguration tezConf, org.apache.tez.client.FrameworkClient frameworkClient)
org.apache.tez.dag.api.client.DAGClient	submitDAGApplication(org.apache.hadoop.yarn.api.records.ApplicationId appId, org.apache.tez.dag.api.DAG dag)

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

addAppMasterLocalFiles, clearAppMasterLocalFiles, create, create, create, create, createFrameworkClient, getAMProxy, getAppMasterApplicationId, getAppMasterStatus, getClientName, newBuilder, preWarm, setAppMasterCredentials, setUpHistoryAclManager, start, stop, submitDAG, waitTillReady

Methods inherited from class java.lang.Object

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

Constructor Detail

MRTezClient

public MRTezClient(String name,
           org.apache.tez.dag.api.TezConfiguration tezConf,
           boolean isSession,
           @Nullable
           Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localResources,
           @Nullable
           org.apache.hadoop.security.Credentials credentials)

Method Detail

submitDAGApplication

public org.apache.tez.dag.api.client.DAGClient submitDAGApplication(org.apache.hadoop.yarn.api.records.ApplicationId appId,
                                                           org.apache.tez.dag.api.DAG dag)
                                                             throws org.apache.tez.dag.api.TezException,
                                                                    IOException

Overrides:

submitDAGApplication in class org.apache.tez.client.TezClient

Throws:

org.apache.tez.dag.api.TezException

IOException

getDAGClient

public static MRDAGClient getDAGClient(org.apache.hadoop.yarn.api.records.ApplicationId appId,
                       org.apache.tez.dag.api.TezConfiguration tezConf,
                       org.apache.tez.client.FrameworkClient frameworkClient)
                                throws IOException,
                                       org.apache.tez.dag.api.TezException

Throws:

IOException

org.apache.tez.dag.api.TezException