Package | Description |
---|---|
org.apache.flink.runtime.taskexecutor | |
org.apache.flink.runtime.taskmanager |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Double> |
BackPressureSampleService.sampleTaskBackPressure(BackPressureSampleableTask task)
Schedules to sample the task back pressure and returns a future that completes with the back
pressure ratio.
|
Modifier and Type | Class and Description |
---|---|
class |
Task
The Task represents one execution of a parallel subtask on a TaskManager.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.