Package | Description |
---|---|
org.apache.tez.dag.api | |
org.apache.tez.runtime.api.events |
Modifier and Type | Method and Description |
---|---|
static VertexLocationHint |
VertexLocationHint.create(List<TaskLocationHint> taskLocationHints) |
Modifier and Type | Method and Description |
---|---|
static DataSourceDescriptor |
DataSourceDescriptor.create(InputDescriptor inputDescriptor,
InputInitializerDescriptor initializerDescriptor,
int numShards,
org.apache.hadoop.security.Credentials credentials,
VertexLocationHint locationHint,
Map<String,org.apache.hadoop.yarn.api.records.LocalResource> additionalLocalFiles)
Create a
DataSourceDescriptor when the data shard calculation
happens in the client at compile time |
void |
VertexManagerPluginContext.reconfigureVertex(int parallelism,
VertexLocationHint locationHint,
Map<String,EdgeProperty> sourceEdgeProperties)
API to reconfigure a
Vertex by changing its task parallelism. |
void |
VertexManagerPluginContext.reconfigureVertex(int parallelism,
VertexLocationHint locationHint,
Map<String,EdgeProperty> sourceEdgeProperties,
Map<String,InputSpecUpdate> rootInputSpecUpdate)
API to reconfigure a
Vertex that is reading root inputs based on
the data read from the root inputs. |
void |
VertexManagerPluginContext.reconfigureVertex(Map<String,InputSpecUpdate> rootInputSpecUpdate,
VertexLocationHint locationHint,
int parallelism)
API to reconfigure a
Vertex that is reading root inputs based on
the data read from the root inputs. |
Vertex |
Vertex.setLocationHint(VertexLocationHint locationHint)
Specify location hints for the tasks of this vertex.
|
void |
VertexManagerPluginContext.setVertexLocationHint(VertexLocationHint locationHint)
Set the placement hint for tasks in this vertex
|
void |
VertexManagerPluginContext.setVertexParallelism(int parallelism,
VertexLocationHint locationHint,
Map<String,EdgeManagerPluginDescriptor> sourceEdgeManagers,
Map<String,InputSpecUpdate> rootInputSpecUpdate)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
VertexLocationHint |
InputConfigureVertexTasksEvent.getLocationHint() |
Modifier and Type | Method and Description |
---|---|
static InputConfigureVertexTasksEvent |
InputConfigureVertexTasksEvent.create(int numTasks,
VertexLocationHint locationHint,
InputSpecUpdate inputSpecUpdate) |
Copyright © 2024 Apache Software Foundation. All rights reserved.