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

Class FlinkSessionJobMetrics

java.lang.Object

org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics

All Implemented Interfaces:

CustomResourceMetrics<FlinkSessionJob>

public class FlinkSessionJobMetrics
extends java.lang.Object
implements CustomResourceMetrics<FlinkSessionJob>

FlinkSessionJob metrics.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	onRemove(FlinkSessionJob sessionJob)
void	onUpdate(FlinkSessionJob sessionJob)

Methods inherited from class java.lang.Object

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

Field Detail

COUNTER_NAME

public static final java.lang.String COUNTER_NAME

See Also:

Constant Field Values

Constructor Detail

FlinkSessionJobMetrics

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

Method Detail

onUpdate

public void onUpdate(FlinkSessionJob sessionJob)

Specified by:

onUpdate in interface CustomResourceMetrics<FlinkSessionJob>

onRemove

public void onRemove(FlinkSessionJob sessionJob)

Specified by:

onRemove in interface CustomResourceMetrics<FlinkSessionJob>