AI 助理
文档备案控制台
开发者社区 大数据与机器学习 实时计算 Flink 正文

Flink CDC有没有考虑在 route 中能将几张表弄成宽表？

Flink CDC有没有考虑在 route 中能将几张表弄成宽表？

展开
收起
真的很搞笑 2023-12-20 08:26:59 184 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 小Lee

    在Flink CDC中，目前还不支持直接在route中将多张表弄成宽表。要实现这个需求，你可以考虑以下方法：

    • 在Flink SQL中使用JOIN或者UNION操作将多张表的数据合并成一张宽表。
    • 在数据源或者数据清洗阶段使用其他工具或者库（如Apache Beam、Spark等）来预处理和转换数据，生成宽表格式的数据。
    • 在Flink CDC任务之外创建一个单独的Flink SQL作业，专门负责宽表的生成和处理。
    2023-12-20 17:00:44
    赞同 展开评论
问答分类：
流计算 实时计算 Flink版
问答标签：
实时计算 Flink版CDC 实时计算 Flink版route 实时计算 Flink版cdc route 云原生多模数据库Lindorm表 云原生多模数据库Lindorm flink
问答地址：
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答
相关问答
实时计算 Flink版
怎样查看Lindorm时序引擎每张表占用的容量
112
1
0
Lindorm时序表怎样重新设置主键PRIMARY KEY
104
1
0
怎样查看Lindorm时序表的insert记录
101
1
0
在Flink把源表和目标宽表都设置了binlog，为啥宽表还是没有实现实时更新呢？
104
0
0
Flink在不重新建catalog的情况下，是不是把这个宽表的binlog属性这样改一下就行？
119
1
0
通过flink的SQL作业生成的宽表的数据结果，跟拼接代码在holo里跑出来的查询结果不一致为什么？
143
0
0
在Flink CDC中，配置的route不生效啊？没有在对应的库里建表
119
0
0
Flink多流部分列更新场景，某条流出现delete操作会转化成最终sink大宽表的update吗？
159
1
0
lindorm 宽表引擎，count表很慢是为什么？
111
0
0
请问下Flink，需求做一个宽表，有大量大表join，如果需要跑大数据量的历史数据该怎么处理？
159
0
0