flink-streaming - UDF の終了時にプログラムで flink セーブポイントを作成する

Question

flink セーブポイントを作成することはできますが、クライアント経由ではなく、プログラムで作成できますか?

ステート プロセッサのドキュメントを確認しましたhttps://nightlies.apache.org/flink/flink-docs-release-1.13/docs/libs/state_processor_api/

しかし、私はかなり混乱しています。ステートフルな UDF の 1 つの onClose() フックでセーブポイントをトリガーしたいのですが、どこから取得すればよいかわかりません。

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

部。UID をランダムに生成する必要があるため、開始する UID を知ることができません。また、変換のグラフを取得するための onClose() フックにもコンテキストがないようです...