Uses of Class
org.apache.flink.kubernetes.operator.api.spec.FlinkDeploymentSpec
-
-
Uses of FlinkDeploymentSpec in org.apache.flink.kubernetes.operator.api
Methods in org.apache.flink.kubernetes.operator.api that return FlinkDeploymentSpec Modifier and Type Method Description FlinkDeploymentSpec
FlinkDeployment. initSpec()
-
Uses of FlinkDeploymentSpec in org.apache.flink.kubernetes.operator.api.spec
Methods in org.apache.flink.kubernetes.operator.api.spec with parameters of type FlinkDeploymentSpec Modifier and Type Method Description static KubernetesDeploymentMode
KubernetesDeploymentMode. getDeploymentMode(FlinkDeploymentSpec spec)
-
Uses of FlinkDeploymentSpec in org.apache.flink.kubernetes.operator.api.status
Methods in org.apache.flink.kubernetes.operator.api.status that return types with arguments of type FlinkDeploymentSpec Modifier and Type Method Description java.lang.Class<FlinkDeploymentSpec>
FlinkDeploymentReconciliationStatus. getSpecClass()
-
Uses of FlinkDeploymentSpec in org.apache.flink.kubernetes.operator.config
Methods in org.apache.flink.kubernetes.operator.config with parameters of type FlinkDeploymentSpec Modifier and Type Method Description static org.apache.flink.configuration.Configuration
FlinkConfigBuilder. buildFrom(java.lang.String namespace, java.lang.String clusterId, FlinkDeploymentSpec spec, org.apache.flink.configuration.Configuration flinkConfig)
org.apache.flink.configuration.Configuration
FlinkConfigManager. getDeployConfig(io.fabric8.kubernetes.api.model.ObjectMeta objectMeta, FlinkDeploymentSpec spec)
Get deployment configuration that will be passed to the Flink Cluster clients during cluster submission.Constructors in org.apache.flink.kubernetes.operator.config with parameters of type FlinkDeploymentSpec Constructor Description FlinkConfigBuilder(java.lang.String namespace, java.lang.String clusterId, FlinkDeploymentSpec spec, org.apache.flink.configuration.Configuration flinkConf)
-
Uses of FlinkDeploymentSpec in org.apache.flink.kubernetes.operator.reconciler.deployment
Methods in org.apache.flink.kubernetes.operator.reconciler.deployment with parameters of type FlinkDeploymentSpec Modifier and Type Method Description void
ApplicationReconciler. deploy(FlinkResourceContext<FlinkDeployment> ctx, FlinkDeploymentSpec spec, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
void
SessionReconciler. deploy(FlinkResourceContext<FlinkDeployment> ctx, FlinkDeploymentSpec spec, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
protected boolean
SessionReconciler. reconcileSpecChange(DiffType diffType, FlinkResourceContext<FlinkDeployment> ctx, org.apache.flink.configuration.Configuration deployConfig, FlinkDeploymentSpec lastReconciledSpec)
-
Uses of FlinkDeploymentSpec in org.apache.flink.kubernetes.operator.utils
Methods in org.apache.flink.kubernetes.operator.utils with parameters of type FlinkDeploymentSpec Modifier and Type Method Description static void
IngressUtils. updateIngressRules(io.fabric8.kubernetes.api.model.ObjectMeta objectMeta, FlinkDeploymentSpec spec, org.apache.flink.configuration.Configuration effectiveConfig, io.fabric8.kubernetes.client.KubernetesClient client)
-