Class and Description |
---|
CoordinationRequest
Root interface for all requests from the client to a
OperatorCoordinator which requests
for a CoordinationResponse . |
CoordinationRequestGateway
Client interface which sends out a
CoordinationRequest and expects for a CoordinationResponse from a OperatorCoordinator . |
CoordinationResponse
Root interface for all responses from a
OperatorCoordinator to the client which is the
response for a CoordinationRequest . |
Class and Description |
---|
CoordinationRequest
Root interface for all requests from the client to a
OperatorCoordinator which requests
for a CoordinationResponse . |
CoordinationRequestGateway
Client interface which sends out a
CoordinationRequest and expects for a CoordinationResponse from a OperatorCoordinator . |
CoordinationResponse
Root interface for all responses from a
OperatorCoordinator to the client which is the
response for a CoordinationRequest . |
Class and Description |
---|
CoordinationRequest
Root interface for all requests from the client to a
OperatorCoordinator which requests
for a CoordinationResponse . |
CoordinationResponse
Root interface for all responses from a
OperatorCoordinator to the client which is the
response for a CoordinationRequest . |
Class and Description |
---|
CoordinationRequest
Root interface for all requests from the client to a
OperatorCoordinator which requests
for a CoordinationResponse . |
CoordinationResponse
Root interface for all responses from a
OperatorCoordinator to the client which is the
response for a CoordinationRequest . |
Class and Description |
---|
OperatorInfo
An interface to access basic properties of an operator in the context of its coordinator.
|
Class and Description |
---|
CoordinationRequest
Root interface for all requests from the client to a
OperatorCoordinator which requests
for a CoordinationResponse . |
CoordinationResponse
Root interface for all responses from a
OperatorCoordinator to the client which is the
response for a CoordinationRequest . |
Class and Description |
---|
OperatorCoordinatorHolder
The
OperatorCoordinatorHolder holds the OperatorCoordinator and manages all its
interactions with the remaining components. |
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
Class and Description |
---|
OperatorCoordinator.Provider
The provider creates an OperatorCoordinator and takes a
OperatorCoordinator.Context to pass to the
OperatorCoordinator. |
Class and Description |
---|
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
Class and Description |
---|
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
Class and Description |
---|
CoordinationRequest
Root interface for all requests from the client to a
OperatorCoordinator which requests
for a CoordinationResponse . |
CoordinationResponse
Root interface for all responses from a
OperatorCoordinator to the client which is the
response for a CoordinationRequest . |
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
Class and Description |
---|
CoordinationRequest
Root interface for all requests from the client to a
OperatorCoordinator which requests
for a CoordinationResponse . |
CoordinationResponse
Root interface for all responses from a
OperatorCoordinator to the client which is the
response for a CoordinationRequest . |
Class and Description |
---|
CoordinationRequest
Root interface for all requests from the client to a
OperatorCoordinator which requests
for a CoordinationResponse . |
CoordinationResponse
Root interface for all responses from a
OperatorCoordinator to the client which is the
response for a CoordinationRequest . |
OperatorCoordinator
A coordinator for runtime operators.
|
OperatorCoordinator.Context
The context gives the OperatorCoordinator access to contextual information and provides a
gateway to interact with other components, such as sending operator events.
|
OperatorCoordinator.Provider
The provider creates an OperatorCoordinator and takes a
OperatorCoordinator.Context to pass to the
OperatorCoordinator. |
OperatorCoordinatorHolder
The
OperatorCoordinatorHolder holds the OperatorCoordinator and manages all its
interactions with the remaining components. |
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
OperatorEventGateway
The gateway through which an Operator can send an
OperatorEvent to the OperatorCoordinator on the JobManager side. |
OperatorEventHandler
Interface for handlers of operator events on the operator side.
|
OperatorInfo
An interface to access basic properties of an operator in the context of its coordinator.
|
TaskNotRunningException
An exception indicating that a target task is not running.
|
Class and Description |
---|
CoordinationRequest
Root interface for all requests from the client to a
OperatorCoordinator which requests
for a CoordinationResponse . |
CoordinationResponse
Root interface for all responses from a
OperatorCoordinator to the client which is the
response for a CoordinationRequest . |
Class and Description |
---|
CoordinationRequest
Root interface for all requests from the client to a
OperatorCoordinator which requests
for a CoordinationResponse . |
CoordinationResponse
Root interface for all responses from a
OperatorCoordinator to the client which is the
response for a CoordinationRequest . |
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
Class and Description |
---|
OperatorCoordinator
A coordinator for runtime operators.
|
OperatorCoordinator.Context
The context gives the OperatorCoordinator access to contextual information and provides a
gateway to interact with other components, such as sending operator events.
|
OperatorCoordinator.Provider
The provider creates an OperatorCoordinator and takes a
OperatorCoordinator.Context to pass to the
OperatorCoordinator. |
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
RecreateOnResetOperatorCoordinator.Provider |
Class and Description |
---|
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
Class and Description |
---|
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
Class and Description |
---|
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
Class and Description |
---|
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
Class and Description |
---|
CoordinationRequest
Root interface for all requests from the client to a
OperatorCoordinator which requests
for a CoordinationResponse . |
CoordinationResponse
Root interface for all responses from a
OperatorCoordinator to the client which is the
response for a CoordinationRequest . |
Class and Description |
---|
OperatorCoordinator.Provider
The provider creates an OperatorCoordinator and takes a
OperatorCoordinator.Context to pass to the
OperatorCoordinator. |
Class and Description |
---|
OperatorCoordinator.Provider
The provider creates an OperatorCoordinator and takes a
OperatorCoordinator.Context to pass to the
OperatorCoordinator. |
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
OperatorEventDispatcher
The dispatcher through which Operators receive
OperatorEvent s and through which they can
send OperatorEvents back to the OperatorCoordinator . |
OperatorEventGateway
The gateway through which an Operator can send an
OperatorEvent to the OperatorCoordinator on the JobManager side. |
OperatorEventHandler
Interface for handlers of operator events on the operator side.
|
Class and Description |
---|
CoordinationRequest
Root interface for all requests from the client to a
OperatorCoordinator which requests
for a CoordinationResponse . |
CoordinationRequestHandler
Coordinator interface which can handle
CoordinationRequest s and response with CoordinationResponse s to the client. |
CoordinationResponse
Root interface for all responses from a
OperatorCoordinator to the client which is the
response for a CoordinationRequest . |
OperatorCoordinator
A coordinator for runtime operators.
|
OperatorCoordinator.Context
The context gives the OperatorCoordinator access to contextual information and provides a
gateway to interact with other components, such as sending operator events.
|
OperatorCoordinator.Provider
The provider creates an OperatorCoordinator and takes a
OperatorCoordinator.Context to pass to the
OperatorCoordinator. |
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
OperatorEventGateway
The gateway through which an Operator can send an
OperatorEvent to the OperatorCoordinator on the JobManager side. |
OperatorEventHandler
Interface for handlers of operator events on the operator side.
|
Class and Description |
---|
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
OperatorEventDispatcher
The dispatcher through which Operators receive
OperatorEvent s and through which they can
send OperatorEvents back to the OperatorCoordinator . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.