Package org.apache.flink.kubernetes.operator.observer.deployment

Class SessionObserver

java.lang.Object

org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver<org.apache.flink.kubernetes.operator.api.FlinkDeployment,FlinkDeploymentObserverContext>

org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

org.apache.flink.kubernetes.operator.observer.deployment.SessionObserver

All Implemented Interfaces:

Observer<org.apache.flink.kubernetes.operator.api.FlinkDeployment>

public class SessionObserver
extends AbstractFlinkDeploymentObserver

The observer of the Mode.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

Modifier and Type	Method	Description
void	observeFlinkCluster(org.apache.flink.kubernetes.operator.api.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

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionObserver

public SessionObserver(FlinkService flinkService,
                       FlinkConfigManager configManager,
                       EventRecorder eventRecorder)

Method Detail

observeFlinkCluster

public void observeFlinkCluster(org.apache.flink.kubernetes.operator.api.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 class AbstractFlinkDeploymentObserver

Parameters:

deployment - the target flinkDeployment resource

context - the context with which the operation is executed

observerContext - Observer context