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来实现。