@InterfaceAudience.Public public class DAG extends Object
Modifier and Type | Method and Description |
---|---|
DAG |
addEdge(Edge edge)
Add an
Edge connecting vertices in the DAG |
DAG |
addEdge(GroupInputEdge edge)
Add a
GroupInputEdge to the 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 |
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 |
addVertex(Vertex vertex) |
static DAG |
create(String name)
Create a DAG with the specified name.
|
VertexGroup |
createVertexGroup(String name,
Vertex... members)
Create a group of vertices that share a common output.
|
String |
getName()
Get the DAG name
|
Vertex |
getVertex(String vertexName) |
DAG |
setAccessControls(DAGAccessControls accessControls)
Set Access controls for the 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.
|
public static DAG create(String name)
name
- the name of the DAGDAG
public DAG addTaskLocalFiles(Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localFiles)
localFiles
- files that must be available locally for each task. These files
may be regular files, archives etc. as specified by the value
elements of the map.DAG
public DAG setCredentials(org.apache.hadoop.security.Credentials credentials)
credentials
- Credentials for the DAGDAG
public VertexGroup createVertexGroup(String name, Vertex... members)
public DAG setAccessControls(DAGAccessControls accessControls)
accessControls
- Access ControlsDAG
public DAG addURIsForCredentials(Collection<URI> uris)
FileSystem
implementations that support
credentials.public DAG addEdge(Edge edge)
Edge
connecting vertices in the DAGedge
- The edge to be addedDAG
public DAG addEdge(GroupInputEdge edge)
GroupInputEdge
to the DAG.edge
- GroupInputEdge
DAG
public String getName()
Copyright © 2014 Apache Software Foundation. All rights reserved.