Package org.apache.flink.kubernetes.operator.metrics

Class FlinkDeploymentMetrics

java.lang.Object

org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

All Implemented Interfaces:

CustomResourceMetrics<FlinkDeployment>

public class FlinkDeploymentMetrics
extends java.lang.Object
implements CustomResourceMetrics<FlinkDeployment>

FlinkDeployment metrics.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	COUNTER_NAME
static java.lang.String	CPU_NAME
static java.lang.String	FLINK_MINOR_VERSION_GROUP_NAME
static java.lang.String	FLINK_VERSION_GROUP_NAME
static java.lang.String	MALFORMED_MINOR_VERSION
static java.lang.String	MEMORY_NAME
static java.lang.String	RESOURCE_USAGE_GROUP_NAME
static java.lang.String	STATUS_GROUP_NAME
static java.lang.String	UNKNOWN_VERSION

Constructor Summary

Constructors

Constructor	Description
FlinkDeploymentMetrics(KubernetesOperatorMetricGroup parentMetricGroup, org.apache.flink.configuration.Configuration configuration)

Method Summary

Modifier and Type	Method	Description
void	onRemove(FlinkDeployment flinkApp)
void	onUpdate(FlinkDeployment flinkApp)

Methods inherited from class java.lang.Object

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

Field Detail

FLINK_VERSION_GROUP_NAME

public static final java.lang.String FLINK_VERSION_GROUP_NAME

See Also:

Constant Field Values

FLINK_MINOR_VERSION_GROUP_NAME

public static final java.lang.String FLINK_MINOR_VERSION_GROUP_NAME

See Also:

Constant Field Values

UNKNOWN_VERSION

public static final java.lang.String UNKNOWN_VERSION

See Also:

Constant Field Values

MALFORMED_MINOR_VERSION

public static final java.lang.String MALFORMED_MINOR_VERSION

See Also:

Constant Field Values

STATUS_GROUP_NAME

public static final java.lang.String STATUS_GROUP_NAME

See Also:

Constant Field Values

RESOURCE_USAGE_GROUP_NAME

public static final java.lang.String RESOURCE_USAGE_GROUP_NAME

See Also:

Constant Field Values

COUNTER_NAME

public static final java.lang.String COUNTER_NAME

See Also:

Constant Field Values

CPU_NAME

public static final java.lang.String CPU_NAME

See Also:

Constant Field Values

MEMORY_NAME

public static final java.lang.String MEMORY_NAME

See Also:

Constant Field Values

Constructor Detail

FlinkDeploymentMetrics

public FlinkDeploymentMetrics(KubernetesOperatorMetricGroup parentMetricGroup,
                              org.apache.flink.configuration.Configuration configuration)

Method Detail

onUpdate

public void onUpdate(FlinkDeployment flinkApp)

Specified by:

onUpdate in interface CustomResourceMetrics<FlinkDeployment>

onRemove

public void onRemove(FlinkDeployment flinkApp)

Specified by:

onRemove in interface CustomResourceMetrics<FlinkDeployment>