Package org.apache.tez.dag.api

Interface Summary

Interface	Description
EdgeManagerPluginContext	Context information provided to EdgeManagerPlugins This interface is not supposed to be implemented by users
VertexManagerPluginContext	Object with API's to interact with the Tez execution engine

Class Summary

Class	Description
DAG	Top level entity that defines the DAG (Directed Acyclic Graph) representing the data flow graph.
DagTypeConverters
DataSinkDescriptor	Defines the output and output committer for a data sink
DataSourceDescriptor	Defines the input and input initializer for a data source
Edge	Edge defines the connection between a producer and consumer vertex in the DAG.
EdgeManagerPlugin	This interface defines the routing of the event between tasks of producer and consumer vertices.
EdgeManagerPluginDescriptor	Describes the @link EdgeManagerPlugin
EdgeManagerPluginOnDemand	This interface defines the routing of the event between tasks of producer and consumer vertices.
EdgeManagerPluginOnDemand.EventRouteMetadata	Class to provide routing metadata for Events to be routed between producer and consumer tasks.
EdgeProperty	An @link EdgeProperty defines the relation between the source and destination vertices of an edge.
EntityDescriptor<T extends EntityDescriptor<T>>	Describes a given user code entity.
GroupInputEdge	A composite edge that represents a common connection between a group of input vertices and a single output vertex.
InputDescriptor	Describes the Input
InputInitializerDescriptor	Describes the InputInitializer
NamedEntityDescriptor<T extends NamedEntityDescriptor<T>>
OutputCommitterDescriptor	Describes the OutputCommitter
OutputDescriptor	Describes the Output
PreWarmVertex	A PreWarmVertex is used to specify parameters to be used to setup prewarmed containers for Tez session mode.
PreWarmVertex.PreWarmVertexConfigBuilder	Setup the prewarm vertex constructor.
ProcessorDescriptor	Describes the Processor
RootInputLeafOutput<T extends EntityDescriptor<T>,S extends EntityDescriptor<S>>
TaskLocationHint	Describes the placements hints for tasks.
TaskLocationHint.TaskBasedLocationAffinity
TezConfiguration	Defines the configurations for Tez.
TezConfigurationConstants	Contains fields which will be set automatically by Tez in the Configuration
TezConstants	Specifies all constant values in Tez
UserPayload	Wrapper class to hold user payloads Provides a version to help in evolving the payloads
Vertex	Defines a vertex in the DAG.
Vertex.VertexExecutionContext	The execution context for a running vertex.
VertexGroup	Represents a virtual collection of vertices whose members can be treated as a single named collection for graph operations.
VertexLocationHint	Describes the placements hints for tasks in a vertex.
VertexManagerPlugin	Interface to plugin user logic into the VertexManager to implement runtime scheduling optimizations and graph reconfiguration.
VertexManagerPluginContext.ScheduleTaskRequest
VertexManagerPluginContext.TaskWithLocationHint	Deprecated
VertexManagerPluginDescriptor	Describes the VertexManagerPlugin

Enum Summary

Enum	Description
EdgeProperty.DataMovementType	Defines the manner of data movement between source and destination tasks.
EdgeProperty.DataSourceType	Determines the lifetime of the data produced on this edge by a source task.
EdgeProperty.SchedulingType	Determines when the destination task is eligible to run, once the source task is eligible to run.
Scope

Exception Summary

Exception	Description
DAGNotRunningException	Checked Exception thrown upon error
DAGSubmissionTimedOut	Exception thrown when DAG submission to a Tez Session times out.
SessionNotRunning	Exception thrown when the client cannot communicate with the Tez Session as the Tez Session is no longer running.
TezException	Checked Exception thrown upon error
TezReflectionException
TezUncheckedException	Unchecked Exception thrown upon error

Annotation Types Summary

Annotation Type	Description
ConfigurationScope