1. 新手站长_郑州云淘科技有限公司首页
  2. 阿里云

Flink中canal-json那个binlog的type怎么能过滤出insert和update？-[阿里云_云淘科技]

匿名 • • 阿里云

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

以下为热心网友提供的参考意见

在Flink中，Canal的JSON消息可以被解析为INSERT、UPDATE或DELETE消息到F在Flink中，Canal的JSON消息可以被解析为INSERT、UPDATE或DELETE消息到Flink SQL系统中。Flink支持将这些变更类型的消息以RowKind的形式表示，具体包括Insert (I+)，Update After (U+)，Update Before (U-)和Delete (D-)等。因此，要过滤出insert和update的操作，可以通过判断RowKind的类型是否为Insert或Update来实现。

本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：https://www.cnzhanzhang.com/12320.html

赞 (0)
匿名
上一篇 2023年12月13日
下一篇 2023年12月13日

相关推荐

新手站长从“心”出发，感谢16年您始终不离不弃。