在执行流之前，有没有办法通过编程检查Flink流作业是否从保存点启动？

public class MyJob implements CheckpointedRestored<Boolean> {

    private boolean isRestored;

    @Override
    public void initializeState(FunctionInitializationContext context) throws Exception {
        // 恢复或初始化作业的状态
        if (isRestored) {
            // 从保存点恢复状态
        } else {
            // 初始化作业的初始状态
        }
    }

    @Override
    public Boolean snapshotState(FunctionSnapshotContext context) throws Exception {
        // 保存作业的状态
        return isRestored;
    }

    @Override
    public void restoreState(Boolean state) throws Exception {
        // 设置作业是否从保存点启动
        isRestored = state;
    }

    public static void main(String[] args) throws Exception {
        // 创建Flink作业
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        // 设置作业的检查点配置
        env.enableCheckpointing(5000);
        // ...
        // 执行作业
        env.execute("My Job");
    }
}