Package | Description |
---|---|
org.apache.tez.dag.api |
Modifier and Type | Method and Description |
---|---|
static ProcessorDescriptor |
ProcessorDescriptor.create(String processorClassName) |
ProcessorDescriptor |
Vertex.getProcessorDescriptor()
Get the vertex task processor descriptor
|
Modifier and Type | Method and Description |
---|---|
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.
|
static PreWarmVertex |
PreWarmVertex.create(String vertexName,
ProcessorDescriptor processorDescriptor,
int parallelism,
org.apache.hadoop.yarn.api.records.Resource taskResource)
Create a
PreWarmVertex to be used in
TezClient.preWarm(PreWarmVertex) It may be necessary to call more
methods to add local files etc on the pre-warm vertex post creation so that
it matches the real DAG vertices. |
Copyright © 2015 Apache Software Foundation. All rights reserved.