flink-streaming - 在关闭 UDF 时以编程方式创建 flink 保存点

Question

是否可以创建一个 flink 保存点，但不能通过客户端，而是以编程方式？

我检查了状态处理器的文档https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/libs/state_processor_api/

但我很困惑。我想在我的一个有状态 UDF 的 onClose() 钩子上触发保存点......我不知道从哪里得到

Savepoint.create(new MemoryStateBackend(), maxParallelism)
    .withOperator("uid1", transformation1)
    .write(savepointPath);

部分。我不知道要开始的 UID，因为我们需要随机生成它们，而且我似乎在 onClose() 钩子上也没有任何上下文来检索转换图......