Uses of Interface
org.apache.flink.kubernetes.operator.service.FlinkService

Packages that use FlinkService

Package	Description
org.apache.flink.kubernetes.operator.observer
org.apache.flink.kubernetes.operator.observer.deployment
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 FlinkService in org.apache.flink.kubernetes.operator.observer

Fields in org.apache.flink.kubernetes.operator.observer declared as FlinkService

Modifier and Type	Field	Description
protected FlinkService	JobStatusObserver.flinkService

Constructors in org.apache.flink.kubernetes.operator.observer with parameters of type FlinkService

Constructor	Description
ClusterHealthObserver(FlinkService flinkService)
JobStatusObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)
SavepointObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)

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

Fields in org.apache.flink.kubernetes.operator.observer.deployment declared as FlinkService

Modifier and Type	Field	Description
protected FlinkService	AbstractFlinkDeploymentObserver.flinkService

Constructors in org.apache.flink.kubernetes.operator.observer.deployment with parameters of type FlinkService

Constructor	Description
AbstractFlinkDeploymentObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)
ApplicationObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)
SessionObserver(FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder)

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

Fields in org.apache.flink.kubernetes.operator.reconciler.deployment declared as FlinkService

Modifier and Type	Field	Description
protected FlinkService	ApplicationReconciler.flinkService
protected FlinkService	SessionReconciler.flinkService

Methods in org.apache.flink.kubernetes.operator.reconciler.deployment that return FlinkService

Modifier and Type	Method	Description
protected abstract FlinkService	AbstractFlinkResourceReconciler.getFlinkService(CR resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)	Get the Flink service related to the resource and context.
protected FlinkService	ApplicationReconciler.getFlinkService(org.apache.flink.kubernetes.operator.api.FlinkDeployment resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
protected FlinkService	SessionReconciler.getFlinkService(org.apache.flink.kubernetes.operator.api.FlinkDeployment resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)

Constructors in org.apache.flink.kubernetes.operator.reconciler.deployment with parameters of type FlinkService

Constructor	Description
ApplicationReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> statusRecorder)
SessionReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> statusRecorder)

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

Methods in org.apache.flink.kubernetes.operator.reconciler.sessionjob that return FlinkService

Modifier and Type	Method	Description
protected FlinkService	SessionJobReconciler.getFlinkService(org.apache.flink.kubernetes.operator.api.FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)

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

Classes in org.apache.flink.kubernetes.operator.service that implement FlinkService

Modifier and Type	Class	Description
class	AbstractFlinkService	An abstract FlinkService containing some common implementations for the native and standalone Flink Services.
class	NativeFlinkService	Implementation of FlinkService submitting and interacting with Native Kubernetes Flink clusters and jobs.
class	StandaloneFlinkService	Implementation of FlinkService submitting and interacting with Standalone Kubernetes Flink clusters and jobs.

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

Modifier and Type	Method	Description
FlinkService	FlinkServiceFactory.getOrCreate(org.apache.flink.kubernetes.operator.api.FlinkDeployment deployment)
FlinkService	FlinkServiceFactory.getOrCreate(org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode deploymentMode)

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

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

Modifier and Type	Method	Description
static boolean	SavepointUtils.triggerSavepointIfNeeded(FlinkService flinkService, org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf)	Triggers any pending manual or periodic savepoints and updates the status accordingly.