问答 2023-12-13 来自:开发者社区

Flink中canal-json那个binlog的type怎么能过滤出insert和update?

Flink中canal-json 那个binlog的type怎么能过滤出insert和update的呀?

问答 2021-12-03 来自:开发者社区

flink zeppelin的type参数(append/update/single)和flink的

如题,这个参数是仅仅zeppelin自身的参数,用于决定如何展示数据之类的逻辑呢? 还是和flink任务也有关系。按照https://www.yuque.com/jeffzhangjianfeng/gldg8w/te2l1c#AzSOu 说法,append模式第一个结果列必须是时间,所以看起来更像是zeppelin自身的要求。 我看了下append方式执行,jdbc仍然使用的upsertS...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注