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 |
---|
CoordinatorStore
CoordinatorStore can be used for sharing some information among OperatorCoordinator instances. |
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 . |
Class and Description |
---|
OperatorCoordinator.Provider
The provider creates an OperatorCoordinator and takes a
OperatorCoordinator.Context to pass to the
OperatorCoordinator. |
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 |
---|
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 . |
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 . |
CoordinatorStore
CoordinatorStore can be used for sharing some information among OperatorCoordinator instances. |
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. |
OperatorCoordinator.SubtaskGateway
The
SubtaskGateway is the way to interact with a specific parallel instance of the
Operator (an Operator subtask), like sending events to the operator. |
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.
|
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 . |
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 |
---|
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 |
---|
CoordinatorStore
CoordinatorStore can be used for sharing some information among OperatorCoordinator instances. |
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. |
OperatorCoordinator.SubtaskGateway
The
SubtaskGateway is the way to interact with a specific parallel instance of the
Operator (an Operator subtask), like sending events to the operator. |
OperatorEvent
Root interface for all events sent between
OperatorCoordinator and an OperatorEventHandler . |
RecreateOnResetOperatorCoordinator.Provider
The provider for a private RecreateOnResetOperatorCoordinator.
|
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 |
---|
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 or operator. |
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. |
OperatorCoordinator.SubtaskGateway
The
SubtaskGateway is the way to interact with a specific parallel instance of the
Operator (an Operator subtask), like sending events to the operator. |
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 . |
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 or operator. |
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. |
OperatorCoordinator.SubtaskGateway
The
SubtaskGateway is the way to interact with a specific parallel instance of the
Operator (an Operator subtask), like sending events to the operator. |
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. |
RecreateOnResetOperatorCoordinator.Provider
The provider for a private RecreateOnResetOperatorCoordinator.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.