Uses of Interface
org.apache.flink.kubernetes.operator.service.FlinkService
-
-
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(FlinkDeployment resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
protected FlinkService
SessionReconciler. getFlinkService(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<FlinkDeployment,FlinkDeploymentStatus> statusRecorder)
SessionReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkService flinkService, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,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(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 abstractFlinkService
containing some common implementations for the native and standalone Flink Services.class
NativeFlinkService
Implementation ofFlinkService
submitting and interacting with Native Kubernetes Flink clusters and jobs.class
StandaloneFlinkService
Implementation ofFlinkService
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(FlinkDeployment deployment)
FlinkService
FlinkServiceFactory. getOrCreate(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, AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf)
Triggers any pending manual or periodic savepoints and updates the status accordingly.
-