org.apache.flink.runtime.rest.handler.legacy.backpressure

Class BackPressureStats

java.lang.Object

org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStats

public class BackPressureStats
extends Object

Back pressure stats for one or more tasks.

The stats are collected by request triggered in BackPressureRequestCoordinator.

Constructor Summary

Constructors

Constructor and Description
BackPressureStats(int requestId, long startTime, long endTime, Map<ExecutionAttemptID,Double> backPressureRatios)

Method Summary

Modifier and Type	Method and Description
Map<ExecutionAttemptID,Double>	getBackPressureRatios()
long	getEndTime()
int	getRequestId()
long	getStartTime()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

BackPressureStats

public BackPressureStats(@Nonnegative
                         int requestId,
                         @Nonnegative
                         long startTime,
                         @Nonnegative
                         long endTime,
                         Map<ExecutionAttemptID,Double> backPressureRatios)

Method Detail

getRequestId

public int getRequestId()

getStartTime

public long getStartTime()

getEndTime

public long getEndTime()

getBackPressureRatios

public Map<ExecutionAttemptID,Double> getBackPressureRatios()

toString

public String toString()

Overrides:

toString in class Object