Class ClusterHealthObserver
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.observer.ClusterHealthObserver
-
public class ClusterHealthObserver extends java.lang.Object
An observer to observe the cluster health.
-
-
Constructor Summary
Constructors Constructor Description ClusterHealthObserver()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
observe(FlinkResourceContext<FlinkDeployment> ctx)
Observe the health of the flink cluster.
-
-
-
Method Detail
-
observe
public void observe(FlinkResourceContext<FlinkDeployment> ctx)
Observe the health of the flink cluster.- Parameters:
ctx
- Resource context.
-
-