Class FlinkSessionJobObserver
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver<FlinkSessionJob,FlinkSessionJobObserverContext>
-
- org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver
-
- All Implemented Interfaces:
Observer<FlinkSessionJob>
public class FlinkSessionJobObserver extends AbstractFlinkResourceObserver<FlinkSessionJob,FlinkSessionJobObserverContext>
The observer ofFlinkSessionJob
.
-
-
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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected FlinkSessionJobObserverContext
getObserverContext(FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
Get the observer context for the current resource.protected boolean
isResourceReadyToBeObserved(FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkSessionJobObserverContext observerContext)
Check whether the resource should be observed.protected void
observeInternal(FlinkSessionJob flinkSessionJob, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, FlinkSessionJobObserverContext observerContext)
Internal observer logic specific to each resource type.protected void
updateStatusToDeployedIfAlreadyUpgraded(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
-
-
-
-
Constructor Detail
-
FlinkSessionJobObserver
public FlinkSessionJobObserver(FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, EventRecorder eventRecorder)
-
-
Method Detail
-
getObserverContext
protected FlinkSessionJobObserverContext getObserverContext(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 classAbstractFlinkResourceObserver<FlinkSessionJob,FlinkSessionJobObserverContext>
- Parameters:
resource
- Resource being observedcontext
- Resource context- Returns:
- Observer context
-
isResourceReadyToBeObserved
protected boolean isResourceReadyToBeObserved(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 classAbstractFlinkResourceObserver<FlinkSessionJob,FlinkSessionJobObserverContext>
- Parameters:
resource
- Current resourcecontext
- Resource contextobserverContext
- Observer context- Returns:
- True if we should observe the resource
-
observeInternal
protected void observeInternal(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 classAbstractFlinkResourceObserver<FlinkSessionJob,FlinkSessionJobObserverContext>
- Parameters:
flinkSessionJob
- Resource to be observedctx
- Resource contextobserverContext
- Observer context
-
updateStatusToDeployedIfAlreadyUpgraded
protected void updateStatusToDeployedIfAlreadyUpgraded(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 classAbstractFlinkResourceObserver<FlinkSessionJob,FlinkSessionJobObserverContext>
- Parameters:
flinkSessionJob
- Flink resource.ctx
- Context for resource.observerContext
- Context for observer.
-
-