Package | Description |
---|---|
org.apache.tez.client | |
org.apache.tez.dag.api |
Modifier and Type | Method and Description |
---|---|
DAGClient |
TezClient.submitDAG(DAG dag)
Submit a DAG.
|
Modifier and Type | Method and Description |
---|---|
DAG |
DAG.addEdge(Edge edge)
Add an
Edge connecting vertices in the DAG |
DAG |
DAG.addEdge(GroupInputEdge edge)
Add a
GroupInputEdge to the DAG. |
DAG |
DAG.addTaskLocalFiles(Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localFiles)
Set the files etc that must be provided to the tasks of this DAG
|
DAG |
DAG.addURIsForCredentials(Collection<URI> uris)
One of the methods that can be used to provide information about required
Credentials when running on a secure cluster.
|
DAG |
DAG.addVertex(Vertex vertex) |
static DAG |
DAG.create(String name)
Create a DAG with the specified name.
|
DAG |
DAG.setAccessControls(DAGAccessControls accessControls)
Set Access controls for the DAG.
|
DAG |
DAG.setCallerContext(CallerContext callerContext)
Set the Context in which Tez is being called.
|
DAG |
DAG.setConf(String property,
String value)
This is currently used to setup additional configuration parameters which will be available
in the DAG configuration used in the AppMaster.
|
DAG |
DAG.setCredentials(org.apache.hadoop.security.Credentials credentials)
One of the methods that can be used to provide information about required
Credentials when running on a secure cluster.
|
DAG |
DAG.setDAGInfo(String dagInfo)
Deprecated.
|
DAG |
DAG.setExecutionContext(Vertex.VertexExecutionContext vertexExecutionContext)
Sets the default execution context for the DAG.
|
DAG |
DAG.setHistoryLogLevel(HistoryLogLevel historyLogLevel)
Set history log level for this DAG.
|
Copyright © 2024 Apache Software Foundation. All rights reserved.