Class SessionObserver
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver<FlinkDeployment,FlinkDeploymentObserverContext>
-
- 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
flinkService, logger
-
Fields inherited from class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
configManager, eventRecorder
-
-
Constructor Summary
Constructors Constructor Description SessionObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
observeFlinkCluster(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)
Observe the flinkApp status when the cluster is ready.-
Methods inherited from class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
clearErrorsIfDeploymentIsHealthy, getObserverContext, isJmDeploymentReady, isSuspendedJob, observeInternal, observeJmDeployment, updateStatusToDeployedIfAlreadyUpgraded
-
Methods inherited from class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
isResourceReadyToBeObserved, observe
-
-
-
-
Constructor Detail
-
SessionObserver
public SessionObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)
-
-
Method Detail
-
observeFlinkCluster
public void observeFlinkCluster(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)
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:
deployment
- the target flinkDeployment resourcecontext
- the context with which the operation is executedobserverContext
- Observer context
-
-