Package | Description |
---|---|
org.apache.flink.runtime.rest.handler.legacy.backpressure |
Modifier and Type | Method and Description |
---|---|
Optional<OperatorBackPressureStats> |
OperatorBackPressureStatsResponse.getOperatorBackPressureStats() |
Optional<OperatorBackPressureStats> |
BackPressureStatsTrackerImpl.getOperatorBackPressureStats(ExecutionJobVertex vertex)
Returns back pressure statistics for a operator.
|
Optional<OperatorBackPressureStats> |
BackPressureStatsTracker.getOperatorBackPressureStats(ExecutionJobVertex vertex)
Returns back pressure statistics for a operator.
|
Modifier and Type | Method and Description |
---|---|
static OperatorBackPressureStatsResponse |
OperatorBackPressureStatsResponse.of(OperatorBackPressureStats operatorBackPressureStats) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.