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

Packages that use FlinkService

Package	Description
org.apache.flink.kubernetes.operator.controller
org.apache.flink.kubernetes.operator.service
org.apache.flink.kubernetes.operator.utils

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

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

Modifier and Type	Method	Description
protected FlinkService	FlinkResourceContext.createFlinkService()
protected FlinkService	FlinkSessionJobContext.createFlinkService()
FlinkService	FlinkResourceContext.getFlinkService()	Get the FlinkService implementation for the current resource.

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

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

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
protected FlinkService	FlinkResourceContextFactory.getFlinkService(FlinkResourceContext<?> ctx)

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	SnapshotUtils.triggerSnapshotIfNeeded(FlinkService flinkService, org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf, SnapshotType snapshotType)	Triggers any pending manual or periodic snapshots and updates the status accordingly.