Uses of Class
org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

Packages that use FlinkResourceContext

Package	Description
org.apache.flink.kubernetes.operator.autoscaler
org.apache.flink.kubernetes.operator.controller
org.apache.flink.kubernetes.operator.observer
org.apache.flink.kubernetes.operator.observer.deployment
org.apache.flink.kubernetes.operator.observer.sessionjob
org.apache.flink.kubernetes.operator.reconciler
org.apache.flink.kubernetes.operator.reconciler.deployment
org.apache.flink.kubernetes.operator.reconciler.sessionjob
org.apache.flink.kubernetes.operator.service
org.apache.flink.kubernetes.operator.utils

Uses of FlinkResourceContext in org.apache.flink.kubernetes.operator.autoscaler

Constructors in org.apache.flink.kubernetes.operator.autoscaler with parameters of type FlinkResourceContext

Constructor

Description

KubernetesJobAutoScalerContext(org.apache.flink.api.common.JobID jobID, org.apache.flink.api.common.JobStatus jobStatus, org.apache.flink.configuration.Configuration configuration, org.apache.flink.metrics.MetricGroup metricGroup, org.apache.flink.util.function.SupplierWithException<org.apache.flink.client.program.rest.RestClusterClient<java.lang.String>,java.lang.Exception> restClientSupplier, FlinkResourceContext<?> resourceContext)

Uses of FlinkResourceContext in org.apache.flink.kubernetes.operator.controller

Subclasses of FlinkResourceContext in org.apache.flink.kubernetes.operator.controller

Modifier and Type	Class	Description
class	FlinkDeploymentContext	Context for reconciling a Flink resource.
class	FlinkSessionJobContext	Context for reconciling a Flink resource.

Constructor parameters in org.apache.flink.kubernetes.operator.controller with type arguments of type FlinkResourceContext

Constructor	Description
FlinkDeploymentContext(FlinkDeployment resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> josdkContext, KubernetesResourceMetricGroup resourceMetricGroup, FlinkConfigManager configManager, java.util.function.Function<FlinkResourceContext<?>,FlinkService> flinkServiceFactory)
FlinkSessionJobContext(FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> josdkContext, KubernetesResourceMetricGroup resourceMetricGroup, FlinkConfigManager configManager, java.util.function.Function<FlinkResourceContext<?>,FlinkService> flinkServiceFactory)

Uses of FlinkResourceContext in org.apache.flink.kubernetes.operator.observer

Methods in org.apache.flink.kubernetes.operator.observer with parameters of type FlinkResourceContext

Modifier and Type	Method	Description
protected abstract boolean	AbstractFlinkResourceObserver.checkIfAlreadyUpgraded(FlinkResourceContext<CR> ctx)	Checks a resource that is currently in the UPGRADING state whether it was already deployed but we simply miss the status information.
protected boolean	AbstractFlinkResourceObserver.isResourceReadyToBeObserved(FlinkResourceContext<CR> ctx)	Check whether the resource should be observed.
void	AbstractFlinkResourceObserver.observe(FlinkResourceContext<CR> ctx)
void	ClusterHealthObserver.observe(FlinkResourceContext<FlinkDeployment> ctx)	Observe the health of the flink cluster.
boolean	JobStatusObserver.observe(FlinkResourceContext<R> ctx)	Observe the status of the flink job.
void	Observer.observe(FlinkResourceContext<CR> ctx)	Observe the flinkApp status, It will reflect the changed status on the flinkApp resource.
void	SnapshotObserver.observeCheckpointStatus(FlinkResourceContext<CR> ctx)
protected abstract void	AbstractFlinkResourceObserver.observeInternal(FlinkResourceContext<CR> ctx)	Internal observer logic specific to each resource type.
void	SnapshotObserver.observeSavepointStatus(FlinkResourceContext<CR> ctx)
protected void	JobStatusObserver.onTargetJobNotFound(FlinkResourceContext<R> ctx)	Callback when no matching target job was found on a cluster where jobs were found.
protected void	JobStatusObserver.onTimeout(FlinkResourceContext<R> ctx)	Callback when list jobs timeout.

Uses of FlinkResourceContext in org.apache.flink.kubernetes.operator.observer.deployment

Methods in org.apache.flink.kubernetes.operator.observer.deployment with parameters of type FlinkResourceContext

Modifier and Type	Method	Description
protected boolean	AbstractFlinkDeploymentObserver.checkIfAlreadyUpgraded(FlinkResourceContext<FlinkDeployment> ctx)
protected abstract void	AbstractFlinkDeploymentObserver.observeFlinkCluster(FlinkResourceContext<FlinkDeployment> ctx)	Observe the flinkApp status when the cluster is ready.
protected void	ApplicationObserver.observeFlinkCluster(FlinkResourceContext<FlinkDeployment> ctx)
void	SessionObserver.observeFlinkCluster(FlinkResourceContext<FlinkDeployment> ctx)
void	AbstractFlinkDeploymentObserver.observeInternal(FlinkResourceContext<FlinkDeployment> ctx)
protected void	AbstractFlinkDeploymentObserver.observeJmDeployment(FlinkResourceContext<FlinkDeployment> ctx)

Uses of FlinkResourceContext in org.apache.flink.kubernetes.operator.observer.sessionjob

Methods in org.apache.flink.kubernetes.operator.observer.sessionjob with parameters of type FlinkResourceContext

Modifier and Type	Method	Description
protected boolean	FlinkSessionJobObserver.checkIfAlreadyUpgraded(FlinkResourceContext<FlinkSessionJob> ctx)
protected boolean	FlinkSessionJobObserver.isResourceReadyToBeObserved(FlinkResourceContext<FlinkSessionJob> ctx)
protected void	FlinkSessionJobObserver.observeInternal(FlinkResourceContext<FlinkSessionJob> ctx)

Uses of FlinkResourceContext in org.apache.flink.kubernetes.operator.reconciler

Methods in org.apache.flink.kubernetes.operator.reconciler with parameters of type FlinkResourceContext

Modifier and Type	Method	Description
static <SPEC extends AbstractFlinkSpec> boolean	ReconciliationUtils.applyValidationErrorAndResetSpec(FlinkResourceContext<? extends AbstractFlinkResource<SPEC,?>> ctx, java.lang.String validationError)	In case of validation errors we need to (temporarily) reset the old spec so that we can reconcile other outstanding changes, instead of simply blocking.
io.javaoperatorsdk.operator.api.reconciler.DeleteControl	Reconciler.cleanup(FlinkResourceContext<CR> context)	This is called when receiving the delete event of custom resource.
void	Reconciler.reconcile(FlinkResourceContext<CR> context)	This is called when receiving the create or update event of the custom resource.
static <STATUS extends CommonStatus<?>,R extends AbstractFlinkResource<?,STATUS>> io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<R>	ReconciliationUtils.toErrorStatusUpdateControl(FlinkResourceContext<R> ctx, java.lang.Exception e, StatusRecorder<R,STATUS> statusRecorder)	Update the resource error status and metrics when the operator encountered an exception during reconciliation.
static void	ReconciliationUtils.updateForReconciliationError(FlinkResourceContext<?> ctx, java.lang.Throwable error)

Uses of FlinkResourceContext in org.apache.flink.kubernetes.operator.reconciler.deployment

Methods in org.apache.flink.kubernetes.operator.reconciler.deployment with parameters of type FlinkResourceContext

Modifier and Type	Method	Description
protected abstract boolean	AbstractJobReconciler.cancelJob(FlinkResourceContext<CR> ctx, SuspendMode suspendMode)	Cancel the job for the given resource using the specified upgrade mode.
protected boolean	ApplicationReconciler.cancelJob(FlinkResourceContext<FlinkDeployment> ctx, SuspendMode suspendMode)
io.javaoperatorsdk.operator.api.reconciler.DeleteControl	AbstractFlinkResourceReconciler.cleanup(FlinkResourceContext<CR> ctx)
protected abstract void	AbstractJobReconciler.cleanupAfterFailedJob(FlinkResourceContext<CR> ctx)	Removes a failed job.
protected void	ApplicationReconciler.cleanupAfterFailedJob(FlinkResourceContext<FlinkDeployment> ctx)
protected abstract io.javaoperatorsdk.operator.api.reconciler.DeleteControl	AbstractFlinkResourceReconciler.cleanupInternal(FlinkResourceContext<CR> ctx)	Shut down and clean up all Flink job/cluster resources.
protected io.javaoperatorsdk.operator.api.reconciler.DeleteControl	ApplicationReconciler.cleanupInternal(FlinkResourceContext<FlinkDeployment> ctx)
io.javaoperatorsdk.operator.api.reconciler.DeleteControl	SessionReconciler.cleanupInternal(FlinkResourceContext<FlinkDeployment> ctx)
abstract void	AbstractFlinkResourceReconciler.deploy(FlinkResourceContext<CR> ctx, SPEC spec, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)	Deploys the target resource spec to Kubernetes.
void	ApplicationReconciler.deploy(FlinkResourceContext<FlinkDeployment> ctx, FlinkDeploymentSpec spec, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
void	SessionReconciler.deploy(FlinkResourceContext<FlinkDeployment> ctx, FlinkDeploymentSpec spec, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
protected AbstractJobReconciler.JobUpgrade	AbstractJobReconciler.getJobUpgrade(FlinkResourceContext<CR> ctx, org.apache.flink.configuration.Configuration deployConfig)
protected AbstractJobReconciler.JobUpgrade	ApplicationReconciler.getJobUpgrade(FlinkResourceContext<FlinkDeployment> ctx, org.apache.flink.configuration.Configuration deployConfig)
protected AbstractJobReconciler.JobUpgrade	AbstractJobReconciler.getUpgradeModeBasedOnStateAge(FlinkResourceContext<CR> ctx, org.apache.flink.configuration.Configuration deployConfig, boolean cancellable)
protected abstract boolean	AbstractFlinkResourceReconciler.readyToReconcile(FlinkResourceContext<CR> ctx)	Check whether the given Flink resource is ready to be reconciled or we are still waiting for any pending operation or condition first.
boolean	AbstractJobReconciler.readyToReconcile(FlinkResourceContext<CR> ctx)
protected boolean	SessionReconciler.readyToReconcile(FlinkResourceContext<FlinkDeployment> ctx)
void	AbstractFlinkResourceReconciler.reconcile(FlinkResourceContext<CR> ctx)
protected abstract boolean	AbstractFlinkResourceReconciler.reconcileOtherChanges(FlinkResourceContext<CR> ctx)	Reconcile any other changes required for this resource that are specific to the reconciler implementation.
boolean	AbstractJobReconciler.reconcileOtherChanges(FlinkResourceContext<CR> ctx)	Triggers any pending manual or periodic snapshots and updates the status accordingly.
boolean	ApplicationReconciler.reconcileOtherChanges(FlinkResourceContext<FlinkDeployment> ctx)
boolean	SessionReconciler.reconcileOtherChanges(FlinkResourceContext<FlinkDeployment> ctx)
protected abstract boolean	AbstractFlinkResourceReconciler.reconcileSpecChange(DiffType diffType, FlinkResourceContext<CR> ctx, org.apache.flink.configuration.Configuration deployConfig, SPEC lastReconciledSpec)	Reconcile spec upgrade on the currently deployed/suspended Flink resource and update the status accordingly.
protected boolean	AbstractJobReconciler.reconcileSpecChange(DiffType diffType, FlinkResourceContext<CR> ctx, org.apache.flink.configuration.Configuration deployConfig, SPEC lastReconciledSpec)
protected boolean	SessionReconciler.reconcileSpecChange(DiffType diffType, FlinkResourceContext<FlinkDeployment> ctx, org.apache.flink.configuration.Configuration deployConfig, FlinkDeploymentSpec lastReconciledSpec)
protected void	AbstractJobReconciler.restoreJob(FlinkResourceContext<CR> ctx, SPEC spec, org.apache.flink.configuration.Configuration deployConfig, boolean requireHaMetadata)
protected void	AbstractJobReconciler.resubmitJob(FlinkResourceContext<CR> ctx, boolean requireHaMetadata)
protected void	AbstractJobReconciler.setUpgradeSavepointPath(FlinkResourceContext<?> ctx, java.lang.String savepointLocation)	Updates the upgrade savepoint field in the JobSpec of the current Flink resource and if snapshot resources are enabled, a new FlinkStateSnapshot will be created.

Uses of FlinkResourceContext in org.apache.flink.kubernetes.operator.reconciler.sessionjob

Methods in org.apache.flink.kubernetes.operator.reconciler.sessionjob with parameters of type FlinkResourceContext

Modifier and Type	Method	Description
protected boolean	SessionJobReconciler.cancelJob(FlinkResourceContext<FlinkSessionJob> ctx, SuspendMode suspendMode)
protected void	SessionJobReconciler.cleanupAfterFailedJob(FlinkResourceContext<FlinkSessionJob> ctx)
io.javaoperatorsdk.operator.api.reconciler.DeleteControl	SessionJobReconciler.cleanupInternal(FlinkResourceContext<FlinkSessionJob> ctx)
void	SessionJobReconciler.deploy(FlinkResourceContext<FlinkSessionJob> ctx, FlinkSessionJobSpec sessionJobSpec, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
boolean	SessionJobReconciler.readyToReconcile(FlinkResourceContext<FlinkSessionJob> ctx)

Uses of FlinkResourceContext in org.apache.flink.kubernetes.operator.service

Methods in org.apache.flink.kubernetes.operator.service that return FlinkResourceContext

Modifier and Type	Method	Description
<CR extends AbstractFlinkResource<?,?>> FlinkResourceContext<CR>	FlinkResourceContextFactory.getResourceContext(CR resource, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)

Methods in org.apache.flink.kubernetes.operator.service with parameters of type FlinkResourceContext

Modifier and Type	Method	Description
protected FlinkService	FlinkResourceContextFactory.getFlinkService(FlinkResourceContext<?> ctx)
boolean	FlinkService.scale(FlinkResourceContext<?> resourceContext, org.apache.flink.configuration.Configuration deployConfig)
boolean	NativeFlinkService.scale(FlinkResourceContext<?> ctx, org.apache.flink.configuration.Configuration deployConfig)
boolean	StandaloneFlinkService.scale(FlinkResourceContext<?> ctx, org.apache.flink.configuration.Configuration deployConfig)

Uses of FlinkResourceContext in org.apache.flink.kubernetes.operator.utils

Methods in org.apache.flink.kubernetes.operator.utils with parameters of type FlinkResourceContext

Modifier and Type	Method	Description
static java.util.function.Supplier<java.util.Set<FlinkStateSnapshot>>	FlinkStateSnapshotUtils.getFlinkStateSnapshotsSupplier(FlinkResourceContext<?> ctx)	Returns a supplier of all relevant FlinkStateSnapshot resources for a given Flink resource.
static boolean	ValidatorUtils.validateSupportedVersion(FlinkResourceContext<?> ctx, EventRecorder eventRecorder)