Flink CDC insert-only changelog mode

2024-08-21 Thread Daniel Henneberger
a tumble window aggregation on the stream of events. We're using the table api exclusively and there's no way to convert a different changelog stream to an insert only stream so I'm pushing this upstream to the connector. I threw up a PR to showcase the implementation. Let me know what you

Re: Flink CDC insert-only changelog mode

2024-08-22 Thread Daniel Henneberger
ype` to distinguish > the type of changelog, and users can filter depending on their need. > > Best, > Hongshun > [1] https://issues.apache.org/jira/browse/FLINK-35067 > > > > > On Thu, Aug 22, 2024 at 9:29 AM Daniel Henneberger < > m...@danielhenneberger.com>