Uses of Class
org.apache.flink.kubernetes.operator.api.FlinkDeployment
-
-
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)
org.apache.flink.configuration.Configuration
FlinkConfigManager. getSessionJobConfig(FlinkDeployment deployment, FlinkSessionJobSpec sessionJobSpec)
Constructors in org.apache.flink.kubernetes.operator.config with parameters of type FlinkDeployment Constructor Description FlinkConfigBuilder(FlinkDeployment deployment, org.apache.flink.configuration.Configuration flinkConfig)
-
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 context)
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 context)
io.javaoperatorsdk.operator.api.reconciler.UpdateControl<FlinkDeployment>
FlinkDeploymentController. reconcile(FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context context)
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)
Constructor parameters in org.apache.flink.kubernetes.operator.controller with type arguments of type FlinkDeployment Constructor Description FlinkDeploymentController(FlinkConfigManager configManager, java.util.Set<FlinkResourceValidator> validators, ReconcilerFactory reconcilerFactory, FlinkDeploymentObserverFactory observerFactory, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder)
-
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(FlinkConfigManager configManager, 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
Methods in org.apache.flink.kubernetes.operator.observer with parameters of type FlinkDeployment Modifier and Type Method Description void
ClusterHealthObserver. observe(FlinkDeployment flinkApp, org.apache.flink.configuration.Configuration deployedConfig)
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)
protected FlinkDeploymentObserverContext
AbstractFlinkDeploymentObserver. getObserverContext(FlinkDeployment resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
Observer<FlinkDeployment>
FlinkDeploymentObserverFactory. getOrCreate(FlinkDeployment flinkApp)
protected boolean
AbstractFlinkDeploymentObserver. isJmDeploymentReady(FlinkDeployment dep)
protected boolean
AbstractFlinkDeploymentObserver. isSuspendedJob(FlinkDeployment deployment)
protected abstract void
AbstractFlinkDeploymentObserver. observeFlinkCluster(FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)
Observe the flinkApp status when the cluster is ready.protected void
ApplicationObserver. observeFlinkCluster(FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)
void
SessionObserver. observeFlinkCluster(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)
void
AbstractFlinkDeploymentObserver. observeInternal(FlinkDeployment flinkDep, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)
protected void
AbstractFlinkDeploymentObserver. observeJmDeployment(FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, org.apache.flink.configuration.Configuration effectiveConfig)
protected void
AbstractFlinkDeploymentObserver. updateStatusToDeployedIfAlreadyUpgraded(FlinkDeployment flinkDep, io.javaoperatorsdk.operator.api.reconciler.Context<?> context, FlinkDeploymentObserverContext observerContext)
Constructors in org.apache.flink.kubernetes.operator.observer.deployment with parameters of type FlinkDeployment Constructor Description FlinkDeploymentObserverContext(FlinkDeployment resource, FlinkConfigManager configManager)
Constructor parameters in org.apache.flink.kubernetes.operator.observer.deployment with type arguments of type FlinkDeployment Constructor Description FlinkDeploymentObserverFactory(FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder)
-
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 protected void
ApplicationReconciler. cancelJob(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, UpgradeMode upgradeMode, org.apache.flink.configuration.Configuration observeConfig)
protected void
ApplicationReconciler. cleanupAfterFailedJob(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration observeConfig)
protected io.javaoperatorsdk.operator.api.reconciler.DeleteControl
ApplicationReconciler. cleanupInternal(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
io.javaoperatorsdk.operator.api.reconciler.DeleteControl
SessionReconciler. cleanupInternal(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
protected void
ApplicationReconciler. deploy(FlinkDeployment relatedResource, FlinkDeploymentSpec spec, FlinkDeploymentStatus status, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
protected void
SessionReconciler. deploy(FlinkDeployment cr, FlinkDeploymentSpec spec, FlinkDeploymentStatus status, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
protected java.util.Optional<UpgradeMode>
ApplicationReconciler. getAvailableUpgradeMode(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration deployConfig, org.apache.flink.configuration.Configuration observeConfig)
protected FlinkService
ApplicationReconciler. getFlinkService(FlinkDeployment resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
protected FlinkService
SessionReconciler. getFlinkService(FlinkDeployment resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
protected org.apache.flink.configuration.Configuration
ApplicationReconciler. getObserveConfig(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
protected org.apache.flink.configuration.Configuration
SessionReconciler. getObserveConfig(FlinkDeployment resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
Reconciler<FlinkDeployment>
ReconcilerFactory. getOrCreate(FlinkDeployment flinkApp)
protected boolean
SessionReconciler. readyToReconcile(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration deployConfig)
boolean
ApplicationReconciler. reconcileOtherChanges(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration observeConfig)
boolean
SessionReconciler. reconcileOtherChanges(FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration observeConfig)
protected boolean
SessionReconciler. reconcileSpecChange(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration observeConfig, org.apache.flink.configuration.Configuration deployConfig, DiffType type)
protected void
SessionReconciler. rollback(FlinkDeployment deployment, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration observeConfig)
protected boolean
AbstractFlinkResourceReconciler. shouldRecoverDeployment(org.apache.flink.configuration.Configuration conf, FlinkDeployment deployment)
Checks whether the JobManager Kubernetes Deployment recovery logic should be initiated.Constructor parameters in org.apache.flink.kubernetes.operator.reconciler.deployment with type arguments of type FlinkDeployment Constructor Description ApplicationReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder)
ReconcilerFactory(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkServiceFactory flinkServiceFactory, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> deploymentStatusRecorder)
SessionReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkService flinkService, FlinkConfigManager configManager, 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)
FlinkService
FlinkServiceFactory. getOrCreate(FlinkDeployment deployment)
-
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.
-