Uses of Class
org.apache.flink.kubernetes.operator.api.spec.FlinkSessionJobSpec
-
-
Uses of FlinkSessionJobSpec in org.apache.flink.kubernetes.operator.api
Methods in org.apache.flink.kubernetes.operator.api that return FlinkSessionJobSpec Modifier and Type Method Description FlinkSessionJobSpec
FlinkSessionJob. initSpec()
-
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)
Get configuration for interacting with session jobs. -
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.api.common.JobID jobID, 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.api.common.JobID jobID, org.apache.flink.configuration.Configuration conf, java.lang.String savepoint)
protected org.apache.flink.runtime.webmonitor.handlers.JarUploadResponseBody
AbstractFlinkService. uploadJar(io.fabric8.kubernetes.api.model.ObjectMeta objectMeta, FlinkSessionJobSpec spec, org.apache.flink.configuration.Configuration conf)
-