Interface | Description |
---|---|
EdgeManagerPluginContext |
Context information provided to
EdgeManagerPlugin s
This interface is not supposed to be implemented by users |
VertexManagerPluginContext |
Object with API's to interact with the Tez execution engine
|
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
Event s 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 | 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 | 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 Type | Description |
---|---|
ConfigurationScope |
Copyright © 2016 Apache Software Foundation. All rights reserved.