Checkpoint 模块

public interface CheckpointCoordinator {
    // 触发检查点
    long triggerCheckpoint() throws Exception;

    // 恢复检查点
    void restoreFromCheckpoint(long checkpointId) throws Exception;

    // 获取最新检查点ID
    long getLatestCheckpointId();
}

public interface CheckpointStorage {
    // 保存检查点
    void saveCheckpoint(Checkpoint checkpoint) throws IOException;

    // 获取检查点
    Checkpoint getCheckpoint(long checkpointId) throws IOException;

    // 获取最新检查点
    Checkpoint getLatestCheckpoint() throws IOException;
}

CheckpointStorage storage = new RedisCheckpointStorage(redissonClient);
CheckpointCoordinator coordinator = new RedisCheckpointCoordinator(
    redissonClient,
    storage,
    "my-job"
);

long checkpointId = coordinator.triggerCheckpoint();
System.out.println("Checkpoint created: " + checkpointId);

long latestId = coordinator.getLatestCheckpointId();
coordinator.restoreFromCheckpoint(latestId);