Flink社区能否考虑将ROWKIND做成元数据metadata,类似于kafka 
connector中的offset和partition等,用户可以使用这些ROWKIND 
metadata进行处理,例如对特定ROWKIND过滤或者答输出数据中添加ROWKIND字段

回复