public class OperatorBackPressureStats extends Object implements Serializable
BackPressureStatsTrackerImpl
.Constructor and Description |
---|
OperatorBackPressureStats(int requestId,
long endTimestamp,
double[] subTaskBackPressureRatios) |
Modifier and Type | Method and Description |
---|---|
double |
getBackPressureRatio(int index)
Returns the back pressure ratio of the given subtask index.
|
long |
getEndTimestamp() |
double |
getMaxBackPressureRatio()
Returns the maximum back pressure ratio of all sub tasks.
|
int |
getNumberOfSubTasks() |
int |
getRequestId() |
String |
toString() |
public OperatorBackPressureStats(int requestId, long endTimestamp, double[] subTaskBackPressureRatios)
public int getRequestId()
public long getEndTimestamp()
public int getNumberOfSubTasks()
public double getBackPressureRatio(int index)
public double getMaxBackPressureRatio()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.