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

Question

我有关于 Flink 的表 API 的问题 （1.13 ）。我有一个包含多个字段的 POJO，其中一个是：

List<String> my_list; 

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

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

当我尝试使用 toRetractStream[MY_POJO] 方法将我的表转换为数据流时，我收到以下错误：

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

原因：位置 11 处的汇柱“my_list”类型不兼容。查询架构： [...， my_list： 数组， ...]Sink schema： [...， my_list： RAW（'java.util.List'， ？）， ...]

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

Answer 1

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

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