开发者社区 问答 正文

Flink 中类似 Struct 的数据结构

Hi

我在做 from Kafka to Hive by Flink 的数据持久化操作,操作方式是 Flink SQL 需要把某一些列,持久化为 Hive Struct 类型 但是发现 Flink Data Type 中没有对应的数据类型,想在社区确认下这个情况是这样的吗?有相关的 JIRA Issue 可以关注吗?

感谢*来自志愿者整理的flink邮件归档

展开
收起
雪哥哥 2021-12-07 16:15:32 1158 分享 版权
1 条回答
写回答
取消 提交回答
  • Hive Struct 在1.9.0中对应 Flink DataTypes.Row. 代码可参见 https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveTypeUtil.java*来自志愿者整理的flink

    2021-12-07 16:35:58
    赞同 展开评论