| 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.DataMovementType dataMovementType,
      org.apache.tez.dag.api.EdgeProperty.DataSourceType dataSourceType,
      org.apache.tez.dag.api.EdgeProperty.SchedulingType schedulingType,
      OutputDescriptor edgeSource,
      InputDescriptor edgeDestination)  | 
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.DataMovementTypes | 
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 © 2018 Apache Software Foundation. All rights reserved.