请问,flinkcdc 怎么根据表名动态分流写到hdfs不同的目录里啊?-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

请问,flinkcdc 怎么根据表名动态分流写到hdfs不同的目录里啊?

来自:PG中文社区技术圈 2022-07-04 21:00:50 651 1

请问,flinkcdc 怎么根据表名动态分流写到hdfs不同的目录里啊?

取消 提交回答
全部回答(1)
  • 云墩墩
    2022-07-05 13:11:28

    通过cdc再维护一张表,通过那张表的信息实现分流的。

    此答案来自钉钉群“【2】Apache Flink China 社区”

    0 0
相关问答

1

回答

请问一个问题,数据通过flink cdc读mysql写入ods层的hudi表,然后再将事实表和维度表

2022-08-09 14:15:04 63浏览量 回答数 1

0

回答

各位大佬,idea中测试使用FlinkCDC SQL 读取Mysql 数据写入Kafka中,代码中创

2022-08-03 13:45:47 64浏览量 回答数 0

0

回答

请问,使用flume 消费kafka数据,上传到hdfs,出现重复消费的数据,是什么原因导致的呢

2022-08-01 16:54:55 161浏览量 回答数 0

1

回答

请教个问题 消费flink的cdc数据 如果有多张表 的数据 怎么做既能保证效率 又能比较优

2022-07-03 18:11:11 139浏览量 回答数 1

0

回答

请教个问题,使用flink-cdc同步mysql数据,将mysql中A表和B表数据同步到kudu合并

2022-06-30 12:41:35 170浏览量 回答数 0

0

回答

请问大佬们 有遇到过flink cdc mongdb 执行flinksql 遇到这样的问题的么?

2022-06-28 16:04:32 159浏览量 回答数 0

1

回答

flink cdc 做数据同步 使用kafka 的时候怎么保证顺序消费啊,只能使用一个分区吗

2022-06-24 13:41:40 91浏览量 回答数 1

0

回答

filinCdc 的sql,多表的时候总报这个错,请问下该怎么解决呀

2022-06-21 10:11:30 86浏览量 回答数 0

1

回答

flink消费kafka的数据写入到hdfs中,我采用了BucketingSink 这个sink将o

2020-04-23 19:32:31 2518浏览量 回答数 1

2

回答

如何实现使用云企业网跨VPC访问文件存储HDFS?

2020-03-31 02:54:40 814浏览量 回答数 2
+关注
0
文章
5744
问答
问答排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载