Package org.apache.flink.kubernetes.operator.service

Class CheckpointHistoryWrapper

java.lang.Object

org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper

All Implemented Interfaces:

org.apache.flink.runtime.rest.messages.ResponseBody

public class CheckpointHistoryWrapper
extends java.lang.Object
implements org.apache.flink.runtime.rest.messages.ResponseBody

Custom Response for handling checkpoint history in a multi-version compatible way.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CheckpointHistoryWrapper.CompletedCheckpointInfo	Information about the latest completed checkpoint/savepoint.
static class	CheckpointHistoryWrapper.PendingCheckpointInfo	Information about the currently pending checkpoint/savepoint.

Constructor Summary

Constructors

Constructor	Description
CheckpointHistoryWrapper()

Method Summary

Modifier and Type	Method	Description
java.util.Optional<CheckpointHistoryWrapper.PendingCheckpointInfo>	getInProgressCheckpoint()
java.util.Optional<CheckpointHistoryWrapper.CompletedCheckpointInfo>	getLatestCompletedCheckpoint()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CheckpointHistoryWrapper

public CheckpointHistoryWrapper()

Method Detail

getInProgressCheckpoint

public java.util.Optional<CheckpointHistoryWrapper.PendingCheckpointInfo> getInProgressCheckpoint()

getLatestCompletedCheckpoint

public java.util.Optional<CheckpointHistoryWrapper.CompletedCheckpointInfo> getLatestCompletedCheckpoint()