Uses of Class
org.apache.flink.kubernetes.operator.api.spec.FlinkDeploymentSpec
-
-
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)
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 flinkConfig)
-
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 protected void
ApplicationReconciler. deploy(FlinkDeployment relatedResource, FlinkDeploymentSpec spec, FlinkDeploymentStatus status, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
protected void
SessionReconciler. deploy(FlinkDeployment cr, FlinkDeploymentSpec spec, FlinkDeploymentStatus status, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
protected org.apache.flink.configuration.Configuration
ApplicationReconciler. getDeployConfig(io.fabric8.kubernetes.api.model.ObjectMeta deployMeta, FlinkDeploymentSpec currentDeploySpec, io.javaoperatorsdk.operator.api.reconciler.Context<?> context)
protected org.apache.flink.configuration.Configuration
SessionReconciler. getDeployConfig(io.fabric8.kubernetes.api.model.ObjectMeta meta, FlinkDeploymentSpec spec, io.javaoperatorsdk.operator.api.reconciler.Context<?> ctx)
-
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 boolean
FlinkUtils. clusterShutdownDisabled(FlinkDeploymentSpec spec)
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)
-