Package | Description |
---|---|
org.apache.tez.dag.api | |
org.apache.tez.runtime.api | |
org.apache.tez.runtime.api.events |
Modifier and Type | Method and Description |
---|---|
abstract void |
VertexManagerPlugin.onRootVertexInitialized(String inputName,
InputDescriptor inputDescriptor,
List<Event> events)
Notification that the inputs of this vertex have initialized
|
Modifier and Type | Method and Description |
---|---|
List<Event> |
OutputFrameworkInterface.close()
Closes the
Output |
List<Event> |
InputFrameworkInterface.close()
Closes the
Input |
List<Event> |
OutputFrameworkInterface.initialize()
Initializes the
Output |
abstract List<Event> |
InputInitializer.initialize()
Run the initializer.
|
List<Event> |
InputFrameworkInterface.initialize()
Initializes the
Input . |
abstract List<Event> |
AbstractLogicalOutput.initialize() |
abstract List<Event> |
AbstractLogicalInput.initialize() |
Modifier and Type | Method and Description |
---|---|
void |
ProcessorFrameworkInterface.handleEvents(List<Event> processorEvents)
Handles user and system generated
Event s. |
void |
OutputFrameworkInterface.handleEvents(List<Event> outputEvents)
Handles user and system generated
Event s, which typically carry
information such as a downstream vertex being ready to consume input. |
void |
InputFrameworkInterface.handleEvents(List<Event> inputEvents)
Handles user and system generated
Event s, which typically carry
information such as an output being available on the previous vertex. |
void |
TaskContext.sendEvents(List<Event> events)
Send Events to the AM and/or dependent Vertices
|
Modifier and Type | Class and Description |
---|---|
class |
CompositeDataMovementEvent
A convenience class to specify multiple DataMovementEvents which share the
same payload.
|
class |
DataMovementEvent
Event used by user code to send information between tasks.
|
class |
InputConfigureVertexTasksEvent
An event typically sent by the
InputInitializer of a vertex
to configure the tasks of the vertex. |
class |
InputDataInformationEvent
Events used by
InputInitializer implementations to provide the
user payload for individual tasks running as part of the Vertex for which an
Initial Input has been configured. |
class |
InputInitializerEvent
An event that is routed to the specified
InputInitializer . |
class |
InputReadErrorEvent
Event generated by an Input to indicate error when trying to retrieve data.
|
class |
InputUpdatePayloadEvent
Events used by
InputInitializer implementations to update the
shared user payload for the Input that is being initialized. |
class |
VertexManagerEvent
Event used to send information from a Task to the VertexManager for a vertex.
|
Copyright © 2016 Apache Software Foundation. All rights reserved.