Uses of Class
org.apache.flink.kubernetes.operator.api.spec.JobSpec
-
Packages that use JobSpec Package Description org.apache.flink.kubernetes.operator.api.utils org.apache.flink.kubernetes.operator.service -
-
Uses of JobSpec in org.apache.flink.kubernetes.operator.api.utils
Methods in org.apache.flink.kubernetes.operator.api.utils that return JobSpec Modifier and Type Method Description static JobSpec
FlinkResourceUtils. getJobSpec(AbstractFlinkResource<? extends AbstractFlinkSpec,? extends CommonStatus<?>> deployment)
static JobSpec
FlinkResourceUtils. getReconciledJobSpec(AbstractFlinkResource<?,?> deployment)
-
Uses of JobSpec in org.apache.flink.kubernetes.operator.service
Methods in org.apache.flink.kubernetes.operator.service with parameters of type JobSpec Modifier and Type Method Description protected abstract void
AbstractFlinkService. deployApplicationCluster(JobSpec jobSpec, org.apache.flink.configuration.Configuration conf)
protected void
NativeFlinkService. deployApplicationCluster(JobSpec jobSpec, org.apache.flink.configuration.Configuration conf)
protected void
StandaloneFlinkService. deployApplicationCluster(JobSpec jobSpec, org.apache.flink.configuration.Configuration conf)
protected void
AbstractFlinkService. runJar(JobSpec job, org.apache.flink.api.common.JobID jobID, org.apache.flink.runtime.webmonitor.handlers.JarUploadResponseBody response, org.apache.flink.configuration.Configuration conf, java.lang.String savepoint)
void
AbstractFlinkService. submitApplicationCluster(JobSpec jobSpec, org.apache.flink.configuration.Configuration conf, boolean requireHaMetadata)
void
FlinkService. submitApplicationCluster(JobSpec jobSpec, org.apache.flink.configuration.Configuration conf, boolean requireHaMetadata)
-