Uses of Class
org.apache.flink.kubernetes.operator.api.spec.FlinkSessionJobSpec
-
-
Uses of FlinkSessionJobSpec in org.apache.flink.kubernetes.operator.api.status
Methods in org.apache.flink.kubernetes.operator.api.status that return types with arguments of type FlinkSessionJobSpec Modifier and Type Method Description java.lang.Class<FlinkSessionJobSpec>
FlinkSessionJobReconciliationStatus. getSpecClass()
-
Uses of FlinkSessionJobSpec in org.apache.flink.kubernetes.operator.artifact
Methods in org.apache.flink.kubernetes.operator.artifact with parameters of type FlinkSessionJobSpec Modifier and Type Method Description java.lang.String
ArtifactManager. generateJarDir(io.fabric8.kubernetes.api.model.ObjectMeta meta, FlinkSessionJobSpec spec)
-
Uses of FlinkSessionJobSpec in org.apache.flink.kubernetes.operator.config
Methods in org.apache.flink.kubernetes.operator.config with parameters of type FlinkSessionJobSpec Modifier and Type Method Description org.apache.flink.configuration.Configuration
FlinkConfigManager. getSessionJobConfig(FlinkDeployment deployment, FlinkSessionJobSpec sessionJobSpec)
-
Uses of FlinkSessionJobSpec in org.apache.flink.kubernetes.operator.reconciler.sessionjob
Methods in org.apache.flink.kubernetes.operator.reconciler.sessionjob with parameters of type FlinkSessionJobSpec Modifier and Type Method Description void
SessionJobReconciler. deploy(FlinkResourceContext<FlinkSessionJob> ctx, FlinkSessionJobSpec sessionJobSpec, org.apache.flink.configuration.Configuration deployConfig, java.util.Optional<java.lang.String> savepoint, boolean requireHaMetadata)
-
Uses of FlinkSessionJobSpec in org.apache.flink.kubernetes.operator.service
Methods in org.apache.flink.kubernetes.operator.service with parameters of type FlinkSessionJobSpec Modifier and Type Method Description org.apache.flink.api.common.JobID
AbstractFlinkService. submitJobToSessionCluster(io.fabric8.kubernetes.api.model.ObjectMeta meta, FlinkSessionJobSpec spec, org.apache.flink.configuration.Configuration conf, java.lang.String savepoint)
org.apache.flink.api.common.JobID
FlinkService. submitJobToSessionCluster(io.fabric8.kubernetes.api.model.ObjectMeta meta, FlinkSessionJobSpec spec, org.apache.flink.configuration.Configuration conf, java.lang.String savepoint)
-