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.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
|
Set<Vertex> |
DAG.getVertices() |
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 © 2016 Apache Software Foundation. All rights reserved.