org.apache.flink.runtime.operators.coordination

Interface CoordinationRequestGateway

All Known Implementing Classes:

ClusterClientJobClientAdapter, EmbeddedJobClient, MiniClusterJobClient

public interface CoordinationRequestGateway

Client interface which sends out a CoordinationRequest and expects for a CoordinationResponse from a OperatorCoordinator.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	sendCoordinationRequest(OperatorID operatorId, CoordinationRequest request) Send out a request to a specified coordinator and return the response.

Method Detail

sendCoordinationRequest

CompletableFuture<CoordinationResponse> sendCoordinationRequest(OperatorID operatorId,
                                                                CoordinationRequest request)

Send out a request to a specified coordinator and return the response.

Parameters:

operatorId - specifies which coordinator to receive the request

request - the request to send

Returns:

the response from the coordinator