Package org.apache.flink.runtime.rest.messages

Class JobVertexBackPressureInfo

java.lang.Object

org.apache.flink.runtime.rest.messages.JobVertexBackPressureInfo

All Implemented Interfaces:

ResponseBody

public class JobVertexBackPressureInfo
extends Object
implements ResponseBody

Response type of the JobVertexBackPressureHandler.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JobVertexBackPressureInfo.SubtaskBackPressureInfo	Nested class to encapsulate the sub tasks back pressure.
static class	JobVertexBackPressureInfo.VertexBackPressureLevel	Level of vertex back-pressure.
static class	JobVertexBackPressureInfo.VertexBackPressureStatus	Status of vertex back-pressure.

Field Summary

Fields

Modifier and Type	Field	Description
static String	DEPRECATED_FIELD_NAME_BACKPRESSURE_LEVEL
static String	FIELD_NAME_BACKPRESSURE_LEVEL
static String	FIELD_NAME_END_TIMESTAMP
static String	FIELD_NAME_STATUS
static String	FIELD_NAME_SUBTASKS

Constructor Summary

Constructors

Constructor	Description
JobVertexBackPressureInfo(JobVertexBackPressureInfo.VertexBackPressureStatus status, JobVertexBackPressureInfo.VertexBackPressureLevel backpressureLevel, Long endTimestamp, List<JobVertexBackPressureInfo.SubtaskBackPressureInfo> subtasks)

Method Summary

Modifier and Type	Method	Description
static JobVertexBackPressureInfo	deprecated()
boolean	equals(Object o)
JobVertexBackPressureInfo.VertexBackPressureLevel	getBackpressureLevel()
Long	getEndTimestamp()
JobVertexBackPressureInfo.VertexBackPressureStatus	getStatus()
List<JobVertexBackPressureInfo.SubtaskBackPressureInfo>	getSubtasks()
int	hashCode()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail

FIELD_NAME_STATUS

public static final String FIELD_NAME_STATUS

See Also:

Constant Field Values

DEPRECATED_FIELD_NAME_BACKPRESSURE_LEVEL

public static final String DEPRECATED_FIELD_NAME_BACKPRESSURE_LEVEL

See Also:

Constant Field Values

FIELD_NAME_BACKPRESSURE_LEVEL

public static final String FIELD_NAME_BACKPRESSURE_LEVEL

See Also:

Constant Field Values

FIELD_NAME_END_TIMESTAMP

public static final String FIELD_NAME_END_TIMESTAMP

See Also:

Constant Field Values

FIELD_NAME_SUBTASKS

public static final String FIELD_NAME_SUBTASKS

See Also:

Constant Field Values

Constructor Detail

JobVertexBackPressureInfo

public JobVertexBackPressureInfo(JobVertexBackPressureInfo.VertexBackPressureStatus status,
                                 JobVertexBackPressureInfo.VertexBackPressureLevel backpressureLevel,
                                 Long endTimestamp,
                                 List<JobVertexBackPressureInfo.SubtaskBackPressureInfo> subtasks)

Method Detail

deprecated

public static JobVertexBackPressureInfo deprecated()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getStatus

public JobVertexBackPressureInfo.VertexBackPressureStatus getStatus()

getBackpressureLevel

@Nullable
public JobVertexBackPressureInfo.VertexBackPressureLevel getBackpressureLevel()

getEndTimestamp

@Nullable
public Long getEndTimestamp()

getSubtasks

@Nullable
public List<JobVertexBackPressureInfo.SubtaskBackPressureInfo> getSubtasks()