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

Class FlinkSessionJobObserver

java.lang.Object

org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver<org.apache.flink.kubernetes.operator.api.FlinkSessionJob,FlinkSessionJobObserverContext>

org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver

All Implemented Interfaces:

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

public class FlinkSessionJobObserver
extends AbstractFlinkResourceObserver<org.apache.flink.kubernetes.operator.api.FlinkSessionJob,FlinkSessionJobObserverContext>

The observer of FlinkSessionJob.

Field Summary

Fields inherited from class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

configManager, eventRecorder, logger

Constructor Summary

Constructors

Constructor	Description
FlinkSessionJobObserver(FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, EventRecorder eventRecorder)

Method Summary

Modifier and Type	Method	Description
protected FlinkSessionJobObserverContext	getObserverContext(org.apache.flink.kubernetes.operator.api.FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)	Get the observer context for the current resource.
protected boolean	isResourceReadyToBeObserved(org.apache.flink.kubernetes.operator.api.FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkSessionJobObserverContext observerContext)	Check whether the resource should be observed.
protected void	observeInternal(org.apache.flink.kubernetes.operator.api.FlinkSessionJob flinkSessionJob, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, FlinkSessionJobObserverContext observerContext)	Internal observer logic specific to each resource type.
protected void	updateStatusToDeployedIfAlreadyUpgraded(org.apache.flink.kubernetes.operator.api.FlinkSessionJob flinkSessionJob, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, FlinkSessionJobObserverContext observerContext)	Checks a resource that is currently in the UPGRADING state whether it was already deployed but we simply miss the status information.

Methods inherited from class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

observe

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkSessionJobObserver

public FlinkSessionJobObserver(FlinkServiceFactory flinkServiceFactory,
                               FlinkConfigManager configManager,
                               EventRecorder eventRecorder)

Method Detail

getObserverContext

protected FlinkSessionJobObserverContext getObserverContext(org.apache.flink.kubernetes.operator.api.FlinkSessionJob resource,
                                                            io.javaoperatorsdk.operator.api.reconciler.Context<?> context)

Description copied from class: AbstractFlinkResourceObserver

Get the observer context for the current resource.

Specified by:

getObserverContext in class AbstractFlinkResourceObserver<org.apache.flink.kubernetes.operator.api.FlinkSessionJob,FlinkSessionJobObserverContext>

Parameters:

resource - Resource being observed

context - Resource context

Returns:

Observer context

isResourceReadyToBeObserved

protected boolean isResourceReadyToBeObserved(org.apache.flink.kubernetes.operator.api.FlinkSessionJob resource,
                                              io.javaoperatorsdk.operator.api.reconciler.Context<?> context,
                                              FlinkSessionJobObserverContext observerContext)

Description copied from class: AbstractFlinkResourceObserver

Check whether the resource should be observed. In certain states such as suspended applications or in-progress upgrades and rollbacks, observing is not necessary.

Overrides:

isResourceReadyToBeObserved in class AbstractFlinkResourceObserver<org.apache.flink.kubernetes.operator.api.FlinkSessionJob,FlinkSessionJobObserverContext>

Parameters:

resource - Current resource

context - Resource context

observerContext - Observer context

Returns:

True if we should observe the resource

observeInternal

protected void observeInternal(org.apache.flink.kubernetes.operator.api.FlinkSessionJob flinkSessionJob,
                               io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx,
                               FlinkSessionJobObserverContext observerContext)

Description copied from class: AbstractFlinkResourceObserver

Internal observer logic specific to each resource type.

Specified by:

observeInternal in class AbstractFlinkResourceObserver<org.apache.flink.kubernetes.operator.api.FlinkSessionJob,FlinkSessionJobObserverContext>

Parameters:

flinkSessionJob - Resource to be observed

ctx - Resource context

observerContext - Observer context

updateStatusToDeployedIfAlreadyUpgraded

protected void updateStatusToDeployedIfAlreadyUpgraded(org.apache.flink.kubernetes.operator.api.FlinkSessionJob flinkSessionJob,
                                                       io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx,
                                                       FlinkSessionJobObserverContext observerContext)

Description copied from class: AbstractFlinkResourceObserver

Checks a resource that is currently in the UPGRADING state whether it was already deployed but we simply miss the status information. After comparing the target resource generation with the one from the possible deployment if they match we update the status to the already DEPLOYED state.

Specified by:

updateStatusToDeployedIfAlreadyUpgraded in class AbstractFlinkResourceObserver<org.apache.flink.kubernetes.operator.api.FlinkSessionJob,FlinkSessionJobObserverContext>

Parameters:

flinkSessionJob - Flink resource.

ctx - Context for resource.

observerContext - Context for observer.