Hi everyone, In my Flink application, I have a table created with ChangelogMode.all().
One of the sinks I want to use requires ChangelogMode.insertOnly(). The only solution that comes to mind is converting my table to a DataStream of Rows, filtering out using RowKind and converting it back to a table. It seems pretty inefficient. I know it's currently not possible to access RowKind from a Table API, but I'm wondering if there is another, more efficient approach here? Thank you.
