Interface CoordinationRequestGateway
-
- All Known Implementing Classes:
ClusterClientJobClientAdapter
,EmbeddedJobClient
,MiniClusterJobClient
public interface CoordinationRequestGateway
Client interface which sends out aCoordinationRequest
and expects for aCoordinationResponse
from aOperatorCoordinator
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description CompletableFuture<CoordinationResponse>
sendCoordinationRequest(String operatorUid, CoordinationRequest request)
Send out a request to a specified coordinator and return the response.
-
-
-
Method Detail
-
sendCoordinationRequest
CompletableFuture<CoordinationResponse> sendCoordinationRequest(String operatorUid, CoordinationRequest request)
Send out a request to a specified coordinator and return the response.On the client side, a unique operatorUid must be defined to identify an operator. Otherwise, the query cannot be executed correctly. Note that we use operatorUid instead of operatorID because the latter is an internal runtime concept that cannot be recognized by the client.
- Parameters:
operatorUid
- specifies which coordinator to receive the requestrequest
- the request to send- Returns:
- the response from the coordinator
-
-