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

Class FlinkDeploymentMetrics

java.lang.Object

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

All Implemented Interfaces:

CustomResourceMetrics<org.apache.flink.kubernetes.operator.api.FlinkDeployment>

public class FlinkDeploymentMetrics
extends java.lang.Object
implements CustomResourceMetrics<org.apache.flink.kubernetes.operator.api.FlinkDeployment>

FlinkDeployment metrics.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	COUNTER_NAME
static java.lang.String	STATUS_GROUP_NAME

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	onRemove(org.apache.flink.kubernetes.operator.api.FlinkDeployment flinkApp)
void	onUpdate(org.apache.flink.kubernetes.operator.api.FlinkDeployment flinkApp)

Methods inherited from class java.lang.Object

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

Field Detail

STATUS_GROUP_NAME

public static final java.lang.String STATUS_GROUP_NAME

See Also:

Constant Field Values

COUNTER_NAME

public static final java.lang.String COUNTER_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(org.apache.flink.kubernetes.operator.api.FlinkDeployment flinkApp)

Specified by:

onUpdate in interface CustomResourceMetrics<org.apache.flink.kubernetes.operator.api.FlinkDeployment>

onRemove

public void onRemove(org.apache.flink.kubernetes.operator.api.FlinkDeployment flinkApp)

Specified by:

onRemove in interface CustomResourceMetrics<org.apache.flink.kubernetes.operator.api.FlinkDeployment>