Table API: Converting ChangelogMode.all() Table to ChangelogMode.insertOnly()

[Yaroslav Tkachenko <ya...@goldsky.com>]

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.