Class SessionObserver
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver<FlinkDeployment>
-
- org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
-
- org.apache.flink.kubernetes.operator.observer.deployment.SessionObserver
-
- All Implemented Interfaces:
Observer<FlinkDeployment>
public class SessionObserver extends AbstractFlinkDeploymentObserver
The observer of theMode.SESSION
cluster.
-
-
Field Summary
-
Fields inherited from class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
logger
-
Fields inherited from class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
eventRecorder
-
-
Constructor Summary
Constructors Constructor Description SessionObserver(EventRecorder eventRecorder)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
observeFlinkCluster(FlinkResourceContext<FlinkDeployment> ctx)
Observe the flinkApp status when the cluster is ready.-
Methods inherited from class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
checkIfAlreadyUpgraded, clearErrorsIfDeploymentIsHealthy, isJmDeploymentReady, isSuspendedJob, observeInternal, observeJmDeployment
-
Methods inherited from class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
isResourceReadyToBeObserved, observe
-
-
-
-
Constructor Detail
-
SessionObserver
public SessionObserver(EventRecorder eventRecorder)
-
-
Method Detail
-
observeFlinkCluster
public void observeFlinkCluster(FlinkResourceContext<FlinkDeployment> ctx)
Description copied from class:AbstractFlinkDeploymentObserver
Observe the flinkApp status when the cluster is ready. It will be implemented by child class to reflect the changed status on the flinkApp resource.- Specified by:
observeFlinkCluster
in classAbstractFlinkDeploymentObserver
- Parameters:
ctx
- the context with which the operation is executed
-
-