| Package | Description | 
|---|---|
| org.apache.tez.dag.api | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
PreWarmVertex
A  
PreWarmVertex is used to specify parameters to be used to setup
 prewarmed containers for Tez session mode. | 
| Modifier and Type | Method and Description | 
|---|---|
Vertex | 
Vertex.addDataSink(String outputName,
           DataSinkDescriptor dataSinkDescriptor)
Specifies an external data sink for a Vertex. 
 | 
Vertex | 
Vertex.addDataSource(String inputName,
             DataSourceDescriptor dataSourceDescriptor)
Specifies an external data source for a Vertex. 
 | 
Vertex | 
Vertex.addTaskLocalFiles(Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localFiles)
Set the files etc that must be provided to the tasks of this vertex 
 | 
static Vertex | 
Vertex.create(String vertexName,
      ProcessorDescriptor processorDescriptor)
Create a new vertex with the given name. 
 | 
static Vertex | 
Vertex.create(String vertexName,
      ProcessorDescriptor processorDescriptor,
      int parallelism)
Create a new vertex with the given name and parallelism. 
 | 
static Vertex | 
Vertex.create(String vertexName,
      ProcessorDescriptor processorDescriptor,
      int parallelism,
      org.apache.hadoop.yarn.api.records.Resource taskResource)
Create a new vertex with the given name. 
 | 
Vertex | 
Edge.getInputVertex()
The @link  
Vertex that provides input to the edge | 
Vertex | 
GroupInputEdge.getOutputVertex()  | 
Vertex | 
Edge.getOutputVertex()
The @link  
Vertex that reads output from the edge | 
Vertex | 
DAG.getVertex(String vertexName)  | 
Vertex | 
Vertex.setConf(String property,
       String value)
This is currently used to setup additional configuration parameters which will be available
 in the Vertex specific configuration used in the AppMaster. 
 | 
Vertex | 
Vertex.setExecutionContext(Vertex.VertexExecutionContext vertexExecutionContext)
Sets the execution context for this Vertex - i.e. 
 | 
Vertex | 
Vertex.setLocationHint(VertexLocationHint locationHint)
Specify location hints for the tasks of this vertex. 
 | 
Vertex | 
Vertex.setTaskEnvironment(Map<String,String> environment)
Set the Key-Value pairs of environment variables for tasks of this vertex. 
 | 
Vertex | 
Vertex.setTaskLaunchCmdOpts(String cmdOpts)
Set the command opts for tasks of this vertex. 
 | 
Vertex | 
Vertex.setVertexManagerPlugin(VertexManagerPluginDescriptor vertexManagerPluginDescriptor)
Specifies a  
VertexManagerPlugin for the vertex. | 
| Modifier and Type | Method and Description | 
|---|---|
List<Vertex> | 
Vertex.getInputVertices()
Get the input vertices for this vertex 
 | 
List<Vertex> | 
Vertex.getOutputVertices()
Get the output vertices for this vertex 
 | 
| Modifier and Type | Method and Description | 
|---|---|
DAG | 
DAG.addVertex(Vertex vertex)  | 
static GroupInputEdge | 
GroupInputEdge.create(VertexGroup inputVertexGroup,
      Vertex outputVertex,
      EdgeProperty edgeProperty,
      InputDescriptor mergedInput)
An Edge that connects a  
VertexGroup to a destination Vertex. | 
static Edge | 
Edge.create(Vertex inputVertex,
      Vertex outputVertex,
      EdgeProperty edgeProperty)
Creates an edge between the specified vertices. 
 | 
VertexGroup | 
DAG.createVertexGroup(String name,
                 Vertex... members)
Create a group of vertices that share a common output. 
 | 
Copyright © 2021 Apache Software Foundation. All rights reserved.