Uses of Class
org.apache.flink.runtime.messages.TaskBackPressureResponse

Packages that use TaskBackPressureResponse

Package	Description
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.jobmanager.slots
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.taskexecutor

Uses of TaskBackPressureResponse in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph that return types with arguments of type TaskBackPressureResponse

Modifier and Type	Method and Description
CompletableFuture<TaskBackPressureResponse>	Execution.requestBackPressure(int requestId, Time timeout) Request the back pressure ratio from the task of this execution.

Uses of TaskBackPressureResponse in org.apache.flink.runtime.jobmanager.slots

Methods in org.apache.flink.runtime.jobmanager.slots that return types with arguments of type TaskBackPressureResponse

Modifier and Type	Method and Description
CompletableFuture<TaskBackPressureResponse>	TaskManagerGateway.requestTaskBackPressure(ExecutionAttemptID executionAttemptID, int requestId, Time timeout) Request the back pressure ratio for the given task.

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

Methods in org.apache.flink.runtime.jobmaster that return types with arguments of type TaskBackPressureResponse

Modifier and Type	Method and Description
CompletableFuture<TaskBackPressureResponse>	RpcTaskManagerGateway.requestTaskBackPressure(ExecutionAttemptID executionAttemptID, int requestId, Time timeout)

Uses of TaskBackPressureResponse in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor that return types with arguments of type TaskBackPressureResponse

Modifier and Type	Method and Description
CompletableFuture<TaskBackPressureResponse>	TaskExecutorGateway.requestTaskBackPressure(ExecutionAttemptID executionAttemptId, int requestId, Time timeout)
CompletableFuture<TaskBackPressureResponse>	TaskExecutor.requestTaskBackPressure(ExecutionAttemptID executionAttemptId, int requestId, Time timeout)