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.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)
Set description info for this DAG that can be used for visualization purposes.
|
Copyright © 2015 Apache Software Foundation. All rights reserved.