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

Class ClusterOverviewWithVersion

java.lang.Object

org.apache.flink.runtime.messages.webmonitor.JobsOverview

org.apache.flink.runtime.messages.webmonitor.ClusterOverview

org.apache.flink.runtime.rest.handler.legacy.messages.ClusterOverviewWithVersion

All Implemented Interfaces:

Serializable, InfoMessage, ResponseBody

public class ClusterOverviewWithVersion
extends ClusterOverview
implements ResponseBody

Cluster overview message including the current Flink version and commit id.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_COMMIT
static String	FIELD_NAME_VERSION

Fields inherited from class org.apache.flink.runtime.messages.webmonitor.ClusterOverview

FIELD_NAME_SLOTS_AVAILABLE, FIELD_NAME_SLOTS_TOTAL, FIELD_NAME_TASKMANAGERS

Fields inherited from class org.apache.flink.runtime.messages.webmonitor.JobsOverview

FIELD_NAME_JOBS_CANCELLED, FIELD_NAME_JOBS_FAILED, FIELD_NAME_JOBS_FINISHED, FIELD_NAME_JOBS_RUNNING

Constructor Summary

Constructors

Constructor and Description
ClusterOverviewWithVersion(int numTaskManagersConnected, int numSlotsTotal, int numSlotsAvailable, int numJobsRunningOrPending, int numJobsFinished, int numJobsCancelled, int numJobsFailed, String version, String commitId)
ClusterOverviewWithVersion(int numTaskManagersConnected, int numSlotsTotal, int numSlotsAvailable, JobsOverview jobs1, JobsOverview jobs2, String version, String commitId)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
static ClusterOverviewWithVersion	fromStatusOverview(ClusterOverview statusOverview, String version, String commitId)
String	getCommitId()
String	getVersion()
int	hashCode()

Methods inherited from class org.apache.flink.runtime.messages.webmonitor.ClusterOverview

getNumSlotsAvailable, getNumSlotsTotal, getNumTaskManagersConnected, toString

Methods inherited from class org.apache.flink.runtime.messages.webmonitor.JobsOverview

combine, create, getNumJobsCancelled, getNumJobsFailed, getNumJobsFinished, getNumJobsRunningOrPending

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_VERSION

public static final String FIELD_NAME_VERSION

See Also:

Constant Field Values

FIELD_NAME_COMMIT

public static final String FIELD_NAME_COMMIT

See Also:

Constant Field Values

Constructor Detail

ClusterOverviewWithVersion

public ClusterOverviewWithVersion(int numTaskManagersConnected,
                                  int numSlotsTotal,
                                  int numSlotsAvailable,
                                  int numJobsRunningOrPending,
                                  int numJobsFinished,
                                  int numJobsCancelled,
                                  int numJobsFailed,
                                  String version,
                                  String commitId)

ClusterOverviewWithVersion

public ClusterOverviewWithVersion(int numTaskManagersConnected,
                                  int numSlotsTotal,
                                  int numSlotsAvailable,
                                  JobsOverview jobs1,
                                  JobsOverview jobs2,
                                  String version,
                                  String commitId)

Method Detail

fromStatusOverview

public static ClusterOverviewWithVersion fromStatusOverview(ClusterOverview statusOverview,
                                                            String version,
                                                            String commitId)

getVersion

public String getVersion()

getCommitId

public String getCommitId()

equals

public boolean equals(Object o)

Overrides:

equals in class ClusterOverview

hashCode

public int hashCode()

Overrides:

hashCode in class ClusterOverview