Package | Description |
---|---|
org.apache.tez.dag.api |
Modifier and Type | Method and Description |
---|---|
static InputDescriptor |
InputDescriptor.create(String inputClassName) |
InputDescriptor |
EdgeProperty.getEdgeDestination() |
InputDescriptor |
DataSourceDescriptor.getInputDescriptor()
Get the
InputDescriptor for this DataSourceDescriptor |
Modifier and Type | Method and Description |
---|---|
static EdgeProperty |
EdgeProperty.create(EdgeManagerPluginDescriptor edgeManagerDescriptor,
org.apache.tez.dag.api.EdgeProperty.DataSourceType dataSourceType,
org.apache.tez.dag.api.EdgeProperty.SchedulingType schedulingType,
OutputDescriptor edgeSource,
InputDescriptor edgeDestination)
Setup an Edge which uses a custom EdgeManager
|
static EdgeProperty |
EdgeProperty.create(org.apache.tez.dag.api.EdgeProperty.DataMovementType dataMovementType,
org.apache.tez.dag.api.EdgeProperty.DataSourceType dataSourceType,
org.apache.tez.dag.api.EdgeProperty.SchedulingType schedulingType,
OutputDescriptor edgeSource,
InputDescriptor edgeDestination)
Setup an EdgeProperty which makes use of one of the provided
EdgeProperty.DataMovementType s |
static DataSourceDescriptor |
DataSourceDescriptor.create(InputDescriptor inputDescriptor,
InputInitializerDescriptor initializerDescriptor,
org.apache.hadoop.security.Credentials credentials)
Create a
DataSourceDescriptor when the data shard calculation
happens in the App Master at runtime |
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 |
static GroupInputEdge |
GroupInputEdge.create(VertexGroup inputVertexGroup,
Vertex outputVertex,
EdgeProperty edgeProperty,
InputDescriptor mergedInput)
An Edge that connects a
VertexGroup to a destination Vertex. |
abstract void |
VertexManagerPlugin.onRootVertexInitialized(String inputName,
InputDescriptor inputDescriptor,
List<Event> events)
Notification that the inputs of this vertex have initialized
|
Copyright © 2024 Apache Software Foundation. All rights reserved.