TableSchema.Builder已废弃，如何改用Schema与ResolvedSchema实现表架构构建？

我来帮你梳理下如何用新的Schema和ResolvedSchema替代原有的TableSchema.Builder逻辑，结合你的代码一步步拆解：

原代码逻辑回顾 #

你的原有代码核心做了三件事：

1. 通过字段名数组和类型数组初始化基础表结构
2. 若存在主键配置，给表结构添加主键约束
3. 最终构建出TableSchema实例

新API的核心区别 #

FLIP-164之后，Schema负责声明式的表结构定义（对应原TableSchema的声明部分），而ResolvedSchema是框架解析、验证后生成的结构化元数据——这个不需要我们手动构建，由Flink框架自动处理。我们只需要定义好Schema，剩下的解析工作交给框架就行。

具体替代步骤 #

1. 构建字段列表 #

原来的fields(names, types)需要转换成Field对象列表，新API要求显式定义字段的空值约束（这是比旧API更严谨的地方）：

// 假设你的names是String[]，types是DataType[]
List<Field> fields = new ArrayList<>();
for (int i = 0; i < names.length; i++) {
    // 如果字段不允许为空，用Field.notNull()
    fields.add(Field.notNull(names[i], types[i]));
    // 如果字段允许为空，替换成Field.optional(names[i], types[i])
}

2. 构建Schema实例 #

用Schema.newBuilder()替代原来的TableSchema.Builder，并添加主键约束（如果存在）：

Schema.Builder schemaBuilder = Schema.newBuilder().fields(fields);
// 对应原代码的主键设置逻辑，参数更简洁直接
primaryKey.ifPresent(pk -> schemaBuilder.primaryKey(pk.getName(), pk.getColumns()));
Schema schema = schemaBuilder.build();

3. 获取ResolvedSchema（框架自动处理） #

ResolvedSchema不需要手动构建，通常在你用Schema注册表后，框架会自动解析生成：

// 示例：在TableEnvironment中注册表时使用Schema
TableEnvironment tableEnv = TableEnvironment.create(...);
tableEnv.createTemporaryTable("my_table", TableDescriptor.forConnector("your-connector")
    .schema(schema)
    // 补充其他连接器配置等
    .build());

// 如果需要获取解析后的最终表结构（比如查看验证后的元数据）
ResolvedSchema resolvedSchema = tableEnv.from("my_table").getResolvedSchema();

如果是测试场景需要手动解析Schema，可以用SchemaValidation工具类：

ResolvedSchema resolvedSchema = SchemaValidation.validate(schema);

关键对应关系 #

注意事项 #

• 字段的空值约束（notNull/optional）要根据业务场景选择，这会直接影响框架的数据验证和处理逻辑
• ResolvedSchema包含更多解析后的元数据，比如主键的实际引用、类型的详细信息等，适合在需要获取最终表结构时使用

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