org.apache.flink.runtime.operators.coordination

Interface CoordinationRequestHandler

All Known Implementing Classes:

CollectSinkOperatorCoordinator, DynamicFilteringDataCollectorOperatorCoordinator

public interface CoordinationRequestHandler

Coordinator interface which can handle CoordinationRequests and response with CoordinationResponses to the client or operator.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	handleCoordinationRequest(CoordinationRequest request) Called when receiving a request from the client or operator.

Method Detail

handleCoordinationRequest

CompletableFuture<CoordinationResponse> handleCoordinationRequest(CoordinationRequest request)

Called when receiving a request from the client or operator.

Parameters:

request - the request received

Returns:

a future containing the response from the coordinator for this request