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 theFlinkService
implementation for the current resource.Constructor parameters in org.apache.flink.kubernetes.operator.controller with type arguments of type FlinkService Constructor Description FlinkDeploymentContext(FlinkDeployment resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> josdkContext, KubernetesResourceMetricGroup resourceMetricGroup, FlinkConfigManager configManager, java.util.function.Function<FlinkResourceContext<?>,FlinkService> flinkServiceFactory)
FlinkSessionJobContext(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 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 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, AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf, SnapshotType snapshotType)
Triggers any pending manual or periodic snapshots and updates the status accordingly.
-