Interface CoordinationRequestHandler
-
- All Known Implementing Classes:
CollectSinkOperatorCoordinator
,DynamicFilteringDataCollectorOperatorCoordinator
public interface CoordinationRequestHandler
Coordinator interface which can handleCoordinationRequest
s and response withCoordinationResponse
s to the client or operator.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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
-
-