Package | Description |
---|---|
org.apache.tez.client | |
org.apache.tez.common | |
org.apache.tez.dag.api | |
org.apache.tez.dag.api.client | |
org.apache.tez.dag.api.client.rpc |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
Modifier and Type | Method and Description |
---|---|
static String |
TezClientUtils.addDefaultsToTaskLaunchCmdOpts(String vOpts,
org.apache.hadoop.conf.Configuration conf) |
static String |
TezClientUtils.addDefaultsToTaskLaunchCmdOpts(String vOpts,
org.apache.hadoop.conf.Configuration conf,
JavaOptsChecker javaOptsChecker) |
protected DAGClientAMProtocolBlockingPB |
TezClient.getAMProxy(org.apache.hadoop.yarn.api.records.ApplicationId appId) |
TezAppMasterStatus |
TezClient.getAppMasterStatus()
Get the status of the App Master executing the DAG
In non-session mode it returns the status of the last submitted DAG App Master
In session mode, it returns the status of the App Master hosting the session
|
void |
TezClient.preWarm(PreWarmVertex preWarmVertex)
API to help pre-allocate containers in session mode.
|
void |
TezClient.start()
Start the client.
|
void |
TezClient.stop()
Stop the client.
|
org.apache.hadoop.yarn.api.records.ApplicationId |
TezYarnClient.submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext appSubmissionContext) |
abstract org.apache.hadoop.yarn.api.records.ApplicationId |
FrameworkClient.submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext appSubmissionContext) |
DAGClient |
TezClient.submitDAG(DAG dag)
Submit a DAG.
|
void |
TezClient.waitTillReady()
Wait till the DAG is ready to be submitted.
|
Modifier and Type | Method and Description |
---|---|
static TezException |
RPCUtil.getRemoteException(String message)
Returns an instance of
TezException |
static TezException |
RPCUtil.getRemoteException(Throwable t)
Returns an instance of
TezException |
Modifier and Type | Method and Description |
---|---|
void |
JavaOptsChecker.checkOpts(String opts) |
static Void |
RPCUtil.unwrapAndThrowException(com.google.protobuf.ServiceException se)
Utility method that unwraps and returns appropriate exceptions.
|
static Void |
RPCUtil.unwrapAndThrowNonIOException(com.google.protobuf.ServiceException se)
Utility method that unwraps and returns appropriate exceptions.
|
Modifier and Type | Class and Description |
---|---|
class |
DAGNotRunningException
Checked Exception thrown upon error
|
class |
DAGSubmissionTimedOut
Exception thrown when DAG submission to a Tez Session times out.
|
class |
SessionNotRunning
Exception thrown when the client cannot communicate with the Tez Session
as the Tez Session is no longer running.
|
class |
TezReflectionException |
Modifier and Type | Method and Description |
---|---|
DAGStatus |
DAGClientTimelineImpl.getDAGStatus(Set<StatusGetOpts> statusOptions) |
abstract DAGStatus |
DAGClientInternal.getDAGStatus(Set<StatusGetOpts> statusOptions)
Get the status of the specified DAG
|
DAGStatus |
DAGClientImpl.getDAGStatus(Set<StatusGetOpts> statusOptions) |
abstract DAGStatus |
DAGClient.getDAGStatus(Set<StatusGetOpts> statusOptions)
Get the status of the specified DAG
|
DAGStatus |
DAGClientTimelineImpl.getDAGStatus(Set<StatusGetOpts> statusOptions,
long timeout) |
abstract DAGStatus |
DAGClientInternal.getDAGStatus(Set<StatusGetOpts> statusOptions,
long timeout)
Get the status of the specified DAG when it reaches a final state, or the timeout expires.
|
DAGStatus |
DAGClientImpl.getDAGStatus(Set<StatusGetOpts> statusOptions,
long timeout) |
abstract DAGStatus |
DAGClient.getDAGStatus(Set<StatusGetOpts> statusOptions,
long timeout)
Get the status of the specified DAG when it reaches a final state, or the timeout expires.
|
protected DAGStatus |
DAGClientImpl.getDAGStatusViaRM()
Get the DAG status via the YARN ResourceManager
|
protected org.codehaus.jettison.json.JSONObject |
DAGClientTimelineImpl.getJsonRootEntity(String url) |
static TimelineReaderFactory.TimelineReaderStrategy |
TimelineReaderFactory.getTimelineReaderStrategy(org.apache.hadoop.conf.Configuration conf,
boolean useHttps,
int connTimeout) |
VertexStatus |
DAGClientTimelineImpl.getVertexStatus(String vertexName,
Set<StatusGetOpts> statusOptions) |
abstract VertexStatus |
DAGClientInternal.getVertexStatus(String vertexName,
Set<StatusGetOpts> statusOptions)
Get the status of a Vertex of a DAG
|
VertexStatus |
DAGClientImpl.getVertexStatus(String vertexName,
Set<StatusGetOpts> statusOptions) |
abstract VertexStatus |
DAGClient.getVertexStatus(String vertexName,
Set<StatusGetOpts> statusOptions)
Get the status of a Vertex of a DAG
|
protected Map<String,DAGClientTimelineImpl.VertexTaskStats> |
DAGClientTimelineImpl.parseTaskStatsForVertexes() |
void |
DAGClientTimelineImpl.tryKillDAG() |
abstract void |
DAGClientInternal.tryKillDAG()
Kill a running DAG
|
void |
DAGClientImpl.tryKillDAG() |
abstract void |
DAGClient.tryKillDAG()
Kill a running DAG
|
DAGStatus |
DAGClientTimelineImpl.waitForCompletion() |
abstract DAGStatus |
DAGClientInternal.waitForCompletion()
Wait for DAG to complete without printing any vertex statuses
|
DAGStatus |
DAGClientImpl.waitForCompletion() |
abstract DAGStatus |
DAGClient.waitForCompletion()
Wait for DAG to complete without printing any vertex statuses
|
DAGStatus |
DAGClientTimelineImpl.waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts) |
abstract DAGStatus |
DAGClientInternal.waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts)
Wait for DAG to complete and periodically print *all* vertices' status.
|
DAGStatus |
DAGClientImpl.waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts) |
abstract DAGStatus |
DAGClient.waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts)
Wait for DAG to complete and periodically print *all* vertices' status.
|
Constructor and Description |
---|
DAGClientTimelineImpl(org.apache.hadoop.yarn.api.records.ApplicationId appId,
String dagId,
TezConfiguration conf,
FrameworkClient frameworkClient,
int connTimeout) |
Modifier and Type | Method and Description |
---|---|
DAGStatus |
DAGClientRPCImpl.getDAGStatus(Set<StatusGetOpts> statusOptions) |
DAGStatus |
DAGClientRPCImpl.getDAGStatus(Set<StatusGetOpts> statusOptions,
long timeout) |
VertexStatus |
DAGClientRPCImpl.getVertexStatus(String vertexName,
Set<StatusGetOpts> statusOptions) |
void |
DAGClientRPCImpl.tryKillDAG() |
DAGStatus |
DAGClientRPCImpl.waitForCompletion() |
DAGStatus |
DAGClientRPCImpl.waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts) |
Copyright © 2016 Apache Software Foundation. All rights reserved.