Uses of Class
org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
-
-
Uses of FlinkResourceContext in org.apache.flink.kubernetes.operator.autoscaler
Methods in org.apache.flink.kubernetes.operator.autoscaler with parameters of type FlinkResourceContext Modifier and Type Method Description boolean
JobAutoScalerImpl. scale(FlinkResourceContext<? extends AbstractFlinkResource<?,?>> ctx)
-
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. -
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 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.protected abstract void
AbstractFlinkResourceObserver. observeInternal(FlinkResourceContext<CR> ctx)
Internal observer logic specific to each resource type.void
SavepointObserver. observeSavepointStatus(FlinkResourceContext<CR> ctx)
protected abstract void
JobStatusObserver. onTimeout(FlinkResourceContext<R> ctx)
Callback when list jobs timeout.protected abstract void
AbstractFlinkResourceObserver. updateStatusToDeployedIfAlreadyUpgraded(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. -
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 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)
protected void
AbstractFlinkDeploymentObserver. updateStatusToDeployedIfAlreadyUpgraded(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. isResourceReadyToBeObserved(FlinkResourceContext<FlinkSessionJob> ctx)
protected void
FlinkSessionJobObserver. observeInternal(FlinkResourceContext<FlinkSessionJob> ctx)
protected void
FlinkSessionJobObserver. updateStatusToDeployedIfAlreadyUpgraded(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 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. -
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 void
AbstractJobReconciler. cancelJob(FlinkResourceContext<CR> ctx, UpgradeMode upgradeMode)
Cancel the job for the given resource using the specified upgrade mode.protected void
ApplicationReconciler. cancelJob(FlinkResourceContext<FlinkDeployment> ctx, UpgradeMode upgradeMode)
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 java.util.Optional<UpgradeMode>
AbstractJobReconciler. getAvailableUpgradeMode(FlinkResourceContext<CR> ctx, org.apache.flink.configuration.Configuration deployConfig)
protected java.util.Optional<UpgradeMode>
ApplicationReconciler. getAvailableUpgradeMode(FlinkResourceContext<FlinkDeployment> ctx, org.apache.flink.configuration.Configuration deployConfig)
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)
boolean
ApplicationReconciler. reconcileOtherChanges(FlinkResourceContext<FlinkDeployment> ctx)
boolean
SessionReconciler. reconcileOtherChanges(FlinkResourceContext<FlinkDeployment> ctx)
protected abstract boolean
AbstractFlinkResourceReconciler. reconcileSpecChange(FlinkResourceContext<CR> ctx, org.apache.flink.configuration.Configuration deployConfig)
Reconcile spec upgrade on the currently deployed/suspended Flink resource and update the status accordingly.protected boolean
AbstractJobReconciler. reconcileSpecChange(FlinkResourceContext<CR> ctx, org.apache.flink.configuration.Configuration deployConfig)
protected boolean
SessionReconciler. reconcileSpecChange(FlinkResourceContext<FlinkDeployment> ctx, org.apache.flink.configuration.Configuration deployConfig)
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 abstract void
AbstractFlinkResourceReconciler. rollback(FlinkResourceContext<CR> ctx)
Rollback deployed resource to the last stable spec.protected void
AbstractJobReconciler. rollback(FlinkResourceContext<CR> ctx)
protected void
SessionReconciler. rollback(FlinkResourceContext<FlinkDeployment> ctx)
boolean
JobAutoScaler. scale(FlinkResourceContext<? extends AbstractFlinkResource<?,?>> ctx)
Called as part of the reconciliation loop.boolean
NoopJobAutoscalerFactory. scale(FlinkResourceContext ctx)
-
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 void
SessionJobReconciler. cancelJob(FlinkResourceContext<FlinkSessionJob> ctx, UpgradeMode upgradeMode)
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)
-