Modifier and Type | Method and Description |
---|---|
CompletableFuture<CoordinationResponse> |
ClusterClientJobClientAdapter.sendCoordinationRequest(OperatorID operatorId,
CoordinationRequest request) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CoordinationResponse> |
EmbeddedJobClient.sendCoordinationRequest(OperatorID operatorId,
CoordinationRequest request) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CoordinationResponse> |
MiniClusterClient.sendCoordinationRequest(JobID jobId,
OperatorID operatorId,
CoordinationRequest request) |
CompletableFuture<CoordinationResponse> |
ClusterClient.sendCoordinationRequest(JobID jobId,
OperatorID operatorId,
CoordinationRequest request)
Sends out a request to a specified coordinator and return the response.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CoordinationResponse> |
RestClusterClient.sendCoordinationRequest(JobID jobId,
OperatorID operatorId,
CoordinationRequest request) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CoordinationResponse> |
Dispatcher.deliverCoordinationRequestToCoordinator(JobID jobId,
OperatorID operatorId,
SerializedValue<CoordinationRequest> serializedRequest,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CoordinationResponse> |
JobMasterGateway.deliverCoordinationRequestToCoordinator(OperatorID operatorId,
SerializedValue<CoordinationRequest> serializedRequest,
Time timeout)
Deliver a coordination request to a specified coordinator and return the response.
|
CompletableFuture<CoordinationResponse> |
JobMaster.deliverCoordinationRequestToCoordinator(OperatorID operatorId,
SerializedValue<CoordinationRequest> serializedRequest,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CoordinationResponse> |
MiniCluster.deliverCoordinationRequestToCoordinator(JobID jobId,
OperatorID operatorId,
SerializedValue<CoordinationRequest> serializedRequest) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CoordinationResponse> |
CoordinationRequestHandler.handleCoordinationRequest(CoordinationRequest request)
Called when receiving a request from the client.
|
CompletableFuture<CoordinationResponse> |
CoordinationRequestGateway.sendCoordinationRequest(OperatorID operatorId,
CoordinationRequest request)
Send out a request to a specified coordinator and return the response.
|
Modifier and Type | Method and Description |
---|---|
SerializedValue<CoordinationResponse> |
ClientCoordinationResponseBody.getSerializedCoordinationResponse() |
Constructor and Description |
---|
ClientCoordinationResponseBody(SerializedValue<CoordinationResponse> serializedCoordinationResponse) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CoordinationResponse> |
SchedulerBase.deliverCoordinationRequestToCoordinator(OperatorID operator,
CoordinationRequest request) |
CompletableFuture<CoordinationResponse> |
SchedulerNG.deliverCoordinationRequestToCoordinator(OperatorID operator,
CoordinationRequest request)
Delivers a coordination request to the
OperatorCoordinator with the given OperatorID and returns the coordinator's response. |
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<CoordinationResponse> |
RestfulGateway.deliverCoordinationRequestToCoordinator(JobID jobId,
OperatorID operatorId,
SerializedValue<CoordinationRequest> serializedRequest,
Time timeout)
Deliver a coordination request to a specified coordinator and return the response.
|
Modifier and Type | Class and Description |
---|---|
class |
CollectCoordinationResponse<T>
A
CoordinationResponse from the coordinator containing the required batch or new results
and other necessary information in serialized form. |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<CoordinationResponse> |
CollectSinkOperatorCoordinator.handleCoordinationRequest(CoordinationRequest request) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.