如何将表转换为包含数组类型的数据流（Flink）？

Question

我有关于 Flink (1.13+) 的 table-api 的问题。我有一个包含多个字段的 POJO，其中之一是：

List<String> my_list; 

我使用该字段的以下声明创建表：

"CREATE TABLE my_table (
   ...
   my_list ARRAY<STRING>,
   ...
)"

当我尝试使用 toRetractStream[MY_POJO] 方法将表转换为 DataStream 时，出现以下错误：

线程“main”org.apache.flink.table.api.ValidationException 中出现异常：查询结果的列类型与未注册表的接收器不匹配。

原因：位置 11 处接收器列“my_list”的类型不兼容。查询架构：[..., my_list: ARRAY, ...] 接收器架构：[..., my_list: RAW('java.util.List', ？），...]

我想避免手动映射每个字段并保持代码干净，有没有解决方案来处理这种数据类型？

Answer 1

我建议尝试新的 API 方法from/toDataStream和from/toChangelogStream. 它们支持各种类和数据类型。

toDataStream还支持映射到具有List成员的 POJO。