| Class | Description |
|---|---|
| CompositeDataMovementEvent |
A convenience class to specify multiple DataMovementEvents which share the
same payload.
|
| DataMovementEvent |
Event used by user code to send information between tasks.
|
| EventProtos | |
| EventProtos.CompositeEventProto |
Protobuf type
CompositeEventProto |
| EventProtos.CompositeEventProto.Builder |
Protobuf type
CompositeEventProto |
| EventProtos.DataMovementEventProto |
Protobuf type
DataMovementEventProto |
| EventProtos.DataMovementEventProto.Builder |
Protobuf type
DataMovementEventProto |
| EventProtos.InputFailedEventProto |
Protobuf type
InputFailedEventProto |
| EventProtos.InputFailedEventProto.Builder |
Protobuf type
InputFailedEventProto |
| EventProtos.InputReadErrorEventProto |
Protobuf type
InputReadErrorEventProto |
| EventProtos.InputReadErrorEventProto.Builder |
Protobuf type
InputReadErrorEventProto |
| EventProtos.RootInputDataInformationEventProto |
Protobuf type
RootInputDataInformationEventProto |
| EventProtos.RootInputDataInformationEventProto.Builder |
Protobuf type
RootInputDataInformationEventProto |
| EventProtos.RootInputInitializerEventProto |
Protobuf type
RootInputInitializerEventProto |
| EventProtos.RootInputInitializerEventProto.Builder |
Protobuf type
RootInputInitializerEventProto |
| EventProtos.VertexManagerEventProto |
Protobuf type
VertexManagerEventProto |
| EventProtos.VertexManagerEventProto.Builder |
Protobuf type
VertexManagerEventProto |
| InputConfigureVertexTasksEvent |
An event typically sent by the
InputInitializer of a vertex
to configure the tasks of the vertex. |
| 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. |
| InputFailedEvent |
Event sent from the AM to an Input to indicate that one of it's sources has
failed - effectively the input is no longer available from the particular
source.
|
| InputInitializerEvent |
An event that is routed to the specified
InputInitializer. |
| InputReadErrorEvent |
Event generated by an Input to indicate error when trying to retrieve data.
|
| InputUpdatePayloadEvent |
Events used by
InputInitializer implementations to update the
shared user payload for the Input that is being initialized. |
| VertexManagerEvent |
Event used to send information from a Task to the VertexManager for a vertex.
|
Copyright © 2016 Apache Software Foundation. All rights reserved.