Uses of Interface
org.apache.flink.runtime.operators.coordination.CoordinationRequest

Packages that use CoordinationRequest

Package	Description
org.apache.flink.client.deployment
org.apache.flink.client.deployment.application
org.apache.flink.client.program
org.apache.flink.client.program.rest
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.jobgraph.tasks
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.operators.coordination
org.apache.flink.runtime.rest.messages.job.coordination
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adaptive
org.apache.flink.runtime.taskexecutor.rpc
org.apache.flink.runtime.webmonitor
org.apache.flink.streaming.api.operators.collect

Uses of CoordinationRequest in org.apache.flink.client.deployment

Methods in org.apache.flink.client.deployment with parameters of type CoordinationRequest

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	ClusterClientJobClientAdapter.sendCoordinationRequest(OperatorID operatorId, CoordinationRequest request)

Uses of CoordinationRequest in org.apache.flink.client.deployment.application

Methods in org.apache.flink.client.deployment.application with parameters of type CoordinationRequest

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	EmbeddedJobClient.sendCoordinationRequest(OperatorID operatorId, CoordinationRequest request)

Uses of CoordinationRequest in org.apache.flink.client.program

Methods in org.apache.flink.client.program with parameters of type CoordinationRequest

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

Uses of CoordinationRequest in org.apache.flink.client.program.rest

Methods in org.apache.flink.client.program.rest with parameters of type CoordinationRequest

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	RestClusterClient.sendCoordinationRequest(JobID jobId, OperatorID operatorId, CoordinationRequest request)

Uses of CoordinationRequest in org.apache.flink.runtime.dispatcher

Method parameters in org.apache.flink.runtime.dispatcher with type arguments of type CoordinationRequest

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	Dispatcher.deliverCoordinationRequestToCoordinator(JobID jobId, OperatorID operatorId, SerializedValue<CoordinationRequest> serializedRequest, Time timeout)

Uses of CoordinationRequest in org.apache.flink.runtime.jobgraph.tasks

Method parameters in org.apache.flink.runtime.jobgraph.tasks with type arguments of type CoordinationRequest

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	TaskOperatorEventGateway.sendRequestToCoordinator(OperatorID operator, SerializedValue<CoordinationRequest> request) Sends a request from current operator to a specified operator coordinator which is identified by the given operator ID and return the response.

Uses of CoordinationRequest in org.apache.flink.runtime.jobmaster

Method parameters in org.apache.flink.runtime.jobmaster with type arguments of type CoordinationRequest

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	JobMaster.deliverCoordinationRequestToCoordinator(OperatorID operatorId, SerializedValue<CoordinationRequest> serializedRequest, Time timeout)
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.sendRequestToCoordinator(OperatorID operatorID, SerializedValue<CoordinationRequest> serializedRequest)
CompletableFuture<CoordinationResponse>	JobMasterOperatorEventGateway.sendRequestToCoordinator(OperatorID operatorID, SerializedValue<CoordinationRequest> request)

Uses of CoordinationRequest in org.apache.flink.runtime.minicluster

Methods in org.apache.flink.runtime.minicluster with parameters of type CoordinationRequest

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	MiniClusterJobClient.sendCoordinationRequest(OperatorID operatorId, CoordinationRequest request)

Method parameters in org.apache.flink.runtime.minicluster with type arguments of type CoordinationRequest

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	MiniCluster.deliverCoordinationRequestToCoordinator(JobID jobId, OperatorID operatorId, SerializedValue<CoordinationRequest> serializedRequest)

Uses of CoordinationRequest in org.apache.flink.runtime.operators.coordination

Methods in org.apache.flink.runtime.operators.coordination with parameters of type CoordinationRequest

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	CoordinationRequestHandler.handleCoordinationRequest(CoordinationRequest request) Called when receiving a request from the client or operator.
CompletableFuture<CoordinationResponse>	CoordinationRequestGateway.sendCoordinationRequest(OperatorID operatorId, CoordinationRequest request) Send out a request to a specified coordinator and return the response.

Uses of CoordinationRequest in org.apache.flink.runtime.rest.messages.job.coordination

Methods in org.apache.flink.runtime.rest.messages.job.coordination that return types with arguments of type CoordinationRequest

Modifier and Type	Method and Description
SerializedValue<CoordinationRequest>	ClientCoordinationRequestBody.getSerializedCoordinationRequest()

Constructor parameters in org.apache.flink.runtime.rest.messages.job.coordination with type arguments of type CoordinationRequest

Constructor and Description
ClientCoordinationRequestBody(SerializedValue<CoordinationRequest> serializedCoordinationRequest)

Uses of CoordinationRequest in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler with parameters of type CoordinationRequest

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.
CompletableFuture<CoordinationResponse>	OperatorCoordinatorHandler.deliverCoordinationRequestToCoordinator(OperatorID operator, CoordinationRequest request) Deliver coordination request from the client to the coordinator.
CompletableFuture<CoordinationResponse>	DefaultOperatorCoordinatorHandler.deliverCoordinationRequestToCoordinator(OperatorID operator, CoordinationRequest request)

Uses of CoordinationRequest in org.apache.flink.runtime.scheduler.adaptive

Methods in org.apache.flink.runtime.scheduler.adaptive with parameters of type CoordinationRequest

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	AdaptiveScheduler.deliverCoordinationRequestToCoordinator(OperatorID operator, CoordinationRequest request)

Uses of CoordinationRequest in org.apache.flink.runtime.taskexecutor.rpc

Method parameters in org.apache.flink.runtime.taskexecutor.rpc with type arguments of type CoordinationRequest

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	RpcTaskOperatorEventGateway.sendRequestToCoordinator(OperatorID operator, SerializedValue<CoordinationRequest> request)

Uses of CoordinationRequest in org.apache.flink.runtime.webmonitor

Method parameters in org.apache.flink.runtime.webmonitor with type arguments of type CoordinationRequest

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.

Uses of CoordinationRequest in org.apache.flink.streaming.api.operators.collect

Classes in org.apache.flink.streaming.api.operators.collect that implement CoordinationRequest

Modifier and Type	Class and Description
class	CollectCoordinationRequest A CoordinationRequest from the client indicating that it wants a new batch of query results.

Methods in org.apache.flink.streaming.api.operators.collect with parameters of type CoordinationRequest

Modifier and Type	Method and Description
CompletableFuture<CoordinationResponse>	CollectSinkOperatorCoordinator.handleCoordinationRequest(CoordinationRequest request)