Class FlinkSessionJobContext
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.controller.FlinkResourceContext<FlinkSessionJob>
-
- org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext
-
public class FlinkSessionJobContext extends FlinkResourceContext<FlinkSessionJob>
Context for reconciling a Flink resource. *
-
-
Constructor Summary
Constructors Constructor Description FlinkSessionJobContext(FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> josdkContext, KubernetesResourceMetricGroup resourceMetricGroup, FlinkResourceContextFactory flinkResourceContextFactory, FlinkConfigManager configManager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.apache.flink.configuration.Configuration
createObserveConfig()
Generate the config that is currently deployed for the resource spec.org.apache.flink.configuration.Configuration
getDeployConfig(AbstractFlinkSpec spec)
Get Flink configuration object for deploying the given spec usingAbstractFlinkResourceReconciler.deploy(org.apache.flink.kubernetes.operator.controller.FlinkResourceContext<CR>, SPEC, org.apache.flink.configuration.Configuration, java.util.Optional<java.lang.String>, boolean)
.FlinkService
getFlinkService()
Get theFlinkService
implementation for the current resource.-
Methods inherited from class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
getObserveConfig
-
-
-
-
Constructor Detail
-
FlinkSessionJobContext
public FlinkSessionJobContext(FlinkSessionJob resource, io.javaoperatorsdk.operator.api.reconciler.Context<?> josdkContext, KubernetesResourceMetricGroup resourceMetricGroup, FlinkResourceContextFactory flinkResourceContextFactory, FlinkConfigManager configManager)
-
-
Method Detail
-
getDeployConfig
public org.apache.flink.configuration.Configuration getDeployConfig(AbstractFlinkSpec spec)
Description copied from class:FlinkResourceContext
Get Flink configuration object for deploying the given spec usingAbstractFlinkResourceReconciler.deploy(org.apache.flink.kubernetes.operator.controller.FlinkResourceContext<CR>, SPEC, org.apache.flink.configuration.Configuration, java.util.Optional<java.lang.String>, boolean)
.- Specified by:
getDeployConfig
in classFlinkResourceContext<FlinkSessionJob>
- Parameters:
spec
- Spec for which the config should be created.- Returns:
- Deployment configuration.
-
getFlinkService
public FlinkService getFlinkService()
Description copied from class:FlinkResourceContext
Get theFlinkService
implementation for the current resource.- Specified by:
getFlinkService
in classFlinkResourceContext<FlinkSessionJob>
- Returns:
- Flink service.
-
createObserveConfig
protected org.apache.flink.configuration.Configuration createObserveConfig()
Description copied from class:FlinkResourceContext
Generate the config that is currently deployed for the resource spec.- Specified by:
createObserveConfig
in classFlinkResourceContext<FlinkSessionJob>
- Returns:
- Deployed config.
-
-