Uses of Class
org.apache.flink.kubernetes.operator.api.status.JobStatus
-
Packages that use JobStatus Package Description org.apache.flink.kubernetes.operator.api.utils org.apache.flink.kubernetes.operator.observer org.apache.flink.kubernetes.operator.utils -
-
Uses of JobStatus in org.apache.flink.kubernetes.operator.api.utils
Methods in org.apache.flink.kubernetes.operator.api.utils that return JobStatus Modifier and Type Method Description static JobStatus
FlinkResourceUtils. getJobStatus(AbstractFlinkResource<?,?> deployment)
-
Uses of JobStatus in org.apache.flink.kubernetes.operator.observer
Methods in org.apache.flink.kubernetes.operator.observer with parameters of type JobStatus Modifier and Type Method Description protected abstract java.util.Optional<org.apache.flink.runtime.client.JobStatusMessage>
JobStatusObserver. filterTargetJob(JobStatus status, java.util.List<org.apache.flink.runtime.client.JobStatusMessage> clusterJobStatuses)
Filter the target job status message by the job list from the cluster. -
Uses of JobStatus in org.apache.flink.kubernetes.operator.utils
Methods in org.apache.flink.kubernetes.operator.utils with parameters of type JobStatus Modifier and Type Method Description static boolean
SnapshotUtils. checkpointInProgress(JobStatus jobStatus)
static boolean
SnapshotUtils. savepointInProgress(JobStatus jobStatus)
-