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.