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

Class FlinkStateSnapshotMetrics

java.lang.Object

org.apache.flink.kubernetes.operator.metrics.FlinkStateSnapshotMetrics

All Implemented Interfaces:

CustomResourceMetrics<FlinkStateSnapshot>

public class FlinkStateSnapshotMetrics
extends java.lang.Object
implements CustomResourceMetrics<FlinkStateSnapshot>

FlinkStateSnapshot metrics.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	CHECKPOINT_GROUP_NAME
static java.lang.String	COUNTER_GROUP_NAME
static java.lang.String	SAVEPOINT_GROUP_NAME
static java.lang.String	STATE_GROUP_NAME

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	onRemove(FlinkStateSnapshot snapshot)
void	onUpdate(FlinkStateSnapshot snapshot)

Methods inherited from class java.lang.Object

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

Field Detail

COUNTER_GROUP_NAME

public static final java.lang.String COUNTER_GROUP_NAME

See Also:

Constant Field Values

STATE_GROUP_NAME

public static final java.lang.String STATE_GROUP_NAME

See Also:

Constant Field Values

CHECKPOINT_GROUP_NAME

public static final java.lang.String CHECKPOINT_GROUP_NAME

See Also:

Constant Field Values

SAVEPOINT_GROUP_NAME

public static final java.lang.String SAVEPOINT_GROUP_NAME

See Also:

Constant Field Values

Constructor Detail

FlinkStateSnapshotMetrics

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

Method Detail

onUpdate

public void onUpdate(FlinkStateSnapshot snapshot)

Specified by:

onUpdate in interface CustomResourceMetrics<FlinkStateSnapshot>

onRemove

public void onRemove(FlinkStateSnapshot snapshot)

Specified by:

onRemove in interface CustomResourceMetrics<FlinkStateSnapshot>