Uses of Class
org.apache.flink.kubernetes.operator.api.FlinkDeployment

Packages that use FlinkDeployment

Package	Description
org.apache.flink.kubernetes.operator.admission.informer
org.apache.flink.kubernetes.operator.api.listener
org.apache.flink.kubernetes.operator.api.spec
org.apache.flink.kubernetes.operator.config
org.apache.flink.kubernetes.operator.controller
org.apache.flink.kubernetes.operator.metrics
org.apache.flink.kubernetes.operator.observer
org.apache.flink.kubernetes.operator.observer.deployment
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
org.apache.flink.kubernetes.operator.validation

Uses of FlinkDeployment in org.apache.flink.kubernetes.operator.admission.informer

Methods in org.apache.flink.kubernetes.operator.admission.informer that return types with arguments of type FlinkDeployment

Modifier and Type	Method	Description
io.fabric8.kubernetes.client.informers.SharedIndexInformer<FlinkDeployment>	InformerManager.getFlinkDepInformer(java.lang.String namespace)

Uses of FlinkDeployment in org.apache.flink.kubernetes.operator.api.listener

Method parameters in org.apache.flink.kubernetes.operator.api.listener with type arguments of type FlinkDeployment

Modifier and Type	Method	Description
void	FlinkResourceListener.onDeploymentEvent(FlinkResourceListener.ResourceEventContext<FlinkDeployment> ctx)
void	FlinkResourceListener.onDeploymentStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkDeployment,FlinkDeploymentStatus> ctx)

Uses of FlinkDeployment in org.apache.flink.kubernetes.operator.api.spec

Methods in org.apache.flink.kubernetes.operator.api.spec with parameters of type FlinkDeployment

Modifier and Type	Method	Description
static KubernetesDeploymentMode	KubernetesDeploymentMode.getDeploymentMode(FlinkDeployment flinkDeployment)

Uses of FlinkDeployment in org.apache.flink.kubernetes.operator.config

Methods in org.apache.flink.kubernetes.operator.config with parameters of type FlinkDeployment

Modifier and Type	Method	Description
static Mode	Mode.getMode(FlinkDeployment flinkApp)	Return the mode of the given FlinkDeployment for Observer and Reconciler.
org.apache.flink.configuration.Configuration	FlinkConfigManager.getObserveConfig(FlinkDeployment deployment)	Get the observe configuration that can be used to interact with already submitted clusters through the Flink rest clients.
org.apache.flink.configuration.Configuration	FlinkConfigManager.getSessionJobConfig(FlinkDeployment deployment, FlinkSessionJobSpec sessionJobSpec)	Get configuration for interacting with session jobs.

Constructors in org.apache.flink.kubernetes.operator.config with parameters of type FlinkDeployment

Constructor	Description
FlinkConfigBuilder(FlinkDeployment deployment, org.apache.flink.configuration.Configuration flinkConf)

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

Methods in org.apache.flink.kubernetes.operator.controller that return types with arguments of type FlinkDeployment

Modifier and Type	Method	Description
io.javaoperatorsdk.operator.api.reconciler.UpdateControl<FlinkDeployment>	FlinkDeploymentController.reconcile(FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<FlinkDeployment>	FlinkDeploymentController.updateErrorStatus(FlinkDeployment flinkDeployment, io.javaoperatorsdk.operator.api.reconciler.Context<FlinkDeployment> context, java.lang.Exception e)

Methods in org.apache.flink.kubernetes.operator.controller with parameters of type FlinkDeployment

Modifier and Type	Method	Description
io.javaoperatorsdk.operator.api.reconciler.DeleteControl	FlinkDeploymentController.cleanup(FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
io.javaoperatorsdk.operator.api.reconciler.UpdateControl<FlinkDeployment>	FlinkDeploymentController.reconcile(FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<FlinkDeployment>	FlinkDeploymentController.updateErrorStatus(FlinkDeployment flinkDeployment, io.javaoperatorsdk.operator.api.reconciler.Context<FlinkDeployment> context, java.lang.Exception e)

Method parameters in org.apache.flink.kubernetes.operator.controller with type arguments of type FlinkDeployment

Modifier and Type	Method	Description
java.util.Map<java.lang.String,io.javaoperatorsdk.operator.processing.event.source.EventSource>	FlinkDeploymentController.prepareEventSources(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkDeployment> context)
io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<FlinkDeployment>	FlinkDeploymentController.updateErrorStatus(FlinkDeployment flinkDeployment, io.javaoperatorsdk.operator.api.reconciler.Context<FlinkDeployment> context, java.lang.Exception e)

Constructors in org.apache.flink.kubernetes.operator.controller with parameters of type FlinkDeployment

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

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

Constructor	Description
FlinkDeploymentController(java.util.Set<FlinkResourceValidator> validators, FlinkResourceContextFactory ctxFactory, ReconcilerFactory reconcilerFactory, FlinkDeploymentObserverFactory observerFactory, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder, CanaryResourceManager<FlinkDeployment> canaryResourceManager)
FlinkDeploymentController(java.util.Set<FlinkResourceValidator> validators, FlinkResourceContextFactory ctxFactory, ReconcilerFactory reconcilerFactory, FlinkDeploymentObserverFactory observerFactory, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder, CanaryResourceManager<FlinkDeployment> canaryResourceManager)

Uses of FlinkDeployment in org.apache.flink.kubernetes.operator.metrics

Methods in org.apache.flink.kubernetes.operator.metrics that return types with arguments of type FlinkDeployment

Modifier and Type	Method	Description
static MetricManager<FlinkDeployment>	MetricManager.createFlinkDeploymentMetricManager(org.apache.flink.configuration.Configuration conf, KubernetesOperatorMetricGroup metricGroup)

Methods in org.apache.flink.kubernetes.operator.metrics with parameters of type FlinkDeployment

Modifier and Type	Method	Description
void	FlinkDeploymentMetrics.onRemove(FlinkDeployment flinkApp)
void	FlinkDeploymentMetrics.onUpdate(FlinkDeployment flinkApp)

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

Method parameters in org.apache.flink.kubernetes.operator.observer with type arguments of type FlinkDeployment

Modifier and Type	Method	Description
void	ClusterHealthObserver.observe(FlinkResourceContext<FlinkDeployment> ctx)	Observe the health of the flink cluster.

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

Methods in org.apache.flink.kubernetes.operator.observer.deployment that return types with arguments of type FlinkDeployment

Modifier and Type	Method	Description
Observer<FlinkDeployment>	FlinkDeploymentObserverFactory.getOrCreate(FlinkDeployment flinkApp)

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

Modifier and Type	Method	Description
protected void	AbstractFlinkDeploymentObserver.clearErrorsIfDeploymentIsHealthy(FlinkDeployment dep)
Observer<FlinkDeployment>	FlinkDeploymentObserverFactory.getOrCreate(FlinkDeployment flinkApp)
protected boolean	AbstractFlinkDeploymentObserver.isJmDeploymentReady(FlinkDeployment dep)
protected boolean	AbstractFlinkDeploymentObserver.isSuspendedJob(FlinkDeployment deployment)

Method parameters in org.apache.flink.kubernetes.operator.observer.deployment with type arguments of type FlinkDeployment

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 FlinkDeployment in org.apache.flink.kubernetes.operator.reconciler

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

Modifier and Type	Method	Description
static java.time.Duration	ReconciliationUtils.rescheduleAfter(JobManagerDeploymentStatus status, FlinkDeployment flinkDeployment, FlinkOperatorConfiguration operatorConfiguration)

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

Methods in org.apache.flink.kubernetes.operator.reconciler.deployment that return types with arguments of type FlinkDeployment

Modifier and Type	Method	Description
Reconciler<FlinkDeployment>	ReconcilerFactory.getOrCreate(FlinkDeployment flinkApp)

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

Modifier and Type	Method	Description
Reconciler<FlinkDeployment>	ReconcilerFactory.getOrCreate(FlinkDeployment flinkApp)
protected boolean	AbstractFlinkResourceReconciler.shouldRecoverDeployment(org.apache.flink.configuration.Configuration conf, FlinkDeployment deployment)	Checks whether the JobManager Kubernetes Deployment recovery logic should be initiated.

Method parameters in org.apache.flink.kubernetes.operator.reconciler.deployment with type arguments of type FlinkDeployment

Modifier and Type	Method	Description
protected void	ApplicationReconciler.cancelJob(FlinkResourceContext<FlinkDeployment> ctx, UpgradeMode upgradeMode)
protected void	ApplicationReconciler.cleanupAfterFailedJob(FlinkResourceContext<FlinkDeployment> ctx)
protected io.javaoperatorsdk.operator.api.reconciler.DeleteControl	ApplicationReconciler.cleanupInternal(FlinkResourceContext<FlinkDeployment> ctx)
io.javaoperatorsdk.operator.api.reconciler.DeleteControl	SessionReconciler.cleanupInternal(FlinkResourceContext<FlinkDeployment> ctx)
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.AvailableUpgradeMode	ApplicationReconciler.getAvailableUpgradeMode(FlinkResourceContext<FlinkDeployment> ctx, org.apache.flink.configuration.Configuration deployConfig)
protected boolean	SessionReconciler.readyToReconcile(FlinkResourceContext<FlinkDeployment> ctx)
boolean	ApplicationReconciler.reconcileOtherChanges(FlinkResourceContext<FlinkDeployment> ctx)
boolean	SessionReconciler.reconcileOtherChanges(FlinkResourceContext<FlinkDeployment> ctx)
protected boolean	SessionReconciler.reconcileSpecChange(FlinkResourceContext<FlinkDeployment> ctx, org.apache.flink.configuration.Configuration deployConfig, FlinkDeploymentSpec lastReconciledSpec)

Constructor parameters in org.apache.flink.kubernetes.operator.reconciler.deployment with type arguments of type FlinkDeployment

Constructor	Description
ApplicationReconciler(EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
ReconcilerFactory(EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> deploymentStatusRecorder, JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
SessionReconciler(EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder)

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

Method parameters in org.apache.flink.kubernetes.operator.reconciler.sessionjob with type arguments of type FlinkDeployment

Modifier and Type	Method	Description
static boolean	SessionJobReconciler.sessionClusterReady(java.util.Optional<FlinkDeployment> flinkDeploymentOpt)

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

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

Modifier and Type	Method	Description
protected void	AbstractFlinkService.cancelJob(FlinkDeployment deployment, UpgradeMode upgradeMode, org.apache.flink.configuration.Configuration conf, boolean deleteClusterAfterSavepoint)
void	FlinkService.cancelJob(FlinkDeployment deployment, UpgradeMode upgradeMode, org.apache.flink.configuration.Configuration conf)
void	NativeFlinkService.cancelJob(FlinkDeployment deployment, UpgradeMode upgradeMode, org.apache.flink.configuration.Configuration configuration)
void	StandaloneFlinkService.cancelJob(FlinkDeployment deployment, UpgradeMode upgradeMode, org.apache.flink.configuration.Configuration conf)
io.fabric8.kubernetes.api.model.PodList	AbstractFlinkService.getJmPodList(FlinkDeployment deployment, org.apache.flink.configuration.Configuration conf)
io.fabric8.kubernetes.api.model.PodList	FlinkService.getJmPodList(FlinkDeployment deployment, org.apache.flink.configuration.Configuration conf)

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

Methods in org.apache.flink.kubernetes.operator.utils that return types with arguments of type FlinkDeployment

Modifier and Type	Method	Description
static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<io.fabric8.kubernetes.api.model.apps.Deployment,FlinkDeployment>	EventSourceUtils.getDeploymentInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkDeployment> context)
static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<FlinkDeployment,FlinkSessionJob>	EventSourceUtils.getFlinkDeploymentInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkSessionJob> context)
static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<FlinkSessionJob,FlinkDeployment>	EventSourceUtils.getSessionJobInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkDeployment> context)

Method parameters in org.apache.flink.kubernetes.operator.utils with type arguments of type FlinkDeployment

Modifier and Type	Method	Description
static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<io.fabric8.kubernetes.api.model.apps.Deployment,FlinkDeployment>	EventSourceUtils.getDeploymentInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkDeployment> context)
static io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource<FlinkSessionJob,FlinkDeployment>	EventSourceUtils.getSessionJobInformerEventSource(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkDeployment> context)

Uses of FlinkDeployment in org.apache.flink.kubernetes.operator.validation

Methods in org.apache.flink.kubernetes.operator.validation with parameters of type FlinkDeployment

Modifier and Type	Method	Description
java.util.Optional<java.lang.String>	DefaultValidator.validateDeployment(FlinkDeployment deployment)
java.util.Optional<java.lang.String>	FlinkResourceValidator.validateDeployment(FlinkDeployment deployment)	Validate and return optional error.

Method parameters in org.apache.flink.kubernetes.operator.validation with type arguments of type FlinkDeployment

Modifier and Type	Method	Description
java.util.Optional<java.lang.String>	DefaultValidator.validateSessionJob(FlinkSessionJob sessionJob, java.util.Optional<FlinkDeployment> sessionOpt)
java.util.Optional<java.lang.String>	FlinkResourceValidator.validateSessionJob(FlinkSessionJob sessionJob, java.util.Optional<FlinkDeployment> session)	Validate and return optional error.