Uses of Class
org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper.PendingCheckpointInfo
-
Packages that use CheckpointHistoryWrapper.PendingCheckpointInfo Package Description org.apache.flink.kubernetes.operator.service -
-
Uses of CheckpointHistoryWrapper.PendingCheckpointInfo in org.apache.flink.kubernetes.operator.service
Methods in org.apache.flink.kubernetes.operator.service that return types with arguments of type CheckpointHistoryWrapper.PendingCheckpointInfo Modifier and Type Method Description org.apache.flink.api.java.tuple.Tuple2<java.util.Optional<CheckpointHistoryWrapper.CompletedCheckpointInfo>,java.util.Optional<CheckpointHistoryWrapper.PendingCheckpointInfo>>
AbstractFlinkService. getCheckpointInfo(org.apache.flink.api.common.JobID jobId, org.apache.flink.configuration.Configuration conf)
org.apache.flink.api.java.tuple.Tuple2<java.util.Optional<CheckpointHistoryWrapper.CompletedCheckpointInfo>,java.util.Optional<CheckpointHistoryWrapper.PendingCheckpointInfo>>
FlinkService. getCheckpointInfo(org.apache.flink.api.common.JobID jobId, org.apache.flink.configuration.Configuration conf)
java.util.Optional<CheckpointHistoryWrapper.PendingCheckpointInfo>
CheckpointHistoryWrapper. getInProgressCheckpoint()
-