是否存在可分析Flink savepoint、获取其表结构与统计信息的API？

Flink 官方没有直接生成符合你要求的 Savepoint 分析报告的开箱即用 API，但你可以基于官方提供的 State Processor API 二次开发实现全量需求，不需要提前预设状态 Schema。

• 第一步：加载 Savepoint 元数据获取全量状态列表
  调用Savepoint.load()方法加载指定路径的 Savepoint 实例，遍历实例内所有算子对应的OperatorState集合，每个算子下的独立命名状态（Keyed State、Operator State、广播状态）就对应你类比的「数据库表」。
• 第二步：统计状态基础信息
  对每个命名状态，使用RawKeyedStateReader（针对 Keyed State）或RawOperatorStateReader（针对 Operator 类状态）读取原始字节数据，无需提前指定状态类型：
  • 遍历所有状态条目统计总条数、总字节占用，对应你要的表行数、总字节大小
  • 记录每条条目的总字节长度，可直接计算得到行字节的最小值、最大值、平均值、标准差等统计值
  • 读取状态绑定的 key、value 序列化器信息，可直接解析得到对应的字段结构，对应你要的「表结构」
• 优化补充
  如果你的状态使用 Flink 内置 POJO 序列化器、Avro 序列化器等结构化序列化方案，可以直接通过序列化器导出完整字段定义，不需要手动解析原始字节。标准差这类统计指标可以直接引入org.apache.commons.math3.stat.descriptive.DescriptiveStatistics工具类实现，无需自行编写统计逻辑。

内容的提问来源于stack exchange，提问作者mab