Thanks, Peter and Wing Yew Poon, for tackling these! I’ve been eager to review, but this week has been hectic. I plan to check out PR #10935 next week, though I’d be happy if someone beats me to it.
Yufei On Mon, Sep 30, 2024 at 3:02 AM Péter Váry <peter.vary.apa...@gmail.com> wrote: > Hi Team, > > The Changelog scan Java API interfaces were created a long time ago by > Anton, but it has not been implemented until yet. There is a Spark > specific SQL implementation for the feature, but the feature is not > available on the Java API. > > The Flink CDC streaming read is one of the often required features [1] > [2]. Flink needs the Java API to provide streaming reads for tables with > deletes. > > Wing Yew Poon implemented the Java API [3]. I did my best reviewing > the PR, but I am not an expert on this part of the code. I would like to > ask some of the planning experts (or anyone else for that matter), to take > a look and validate too. > > Thanks, > Peter > > [1] - https://github.com/apache/iceberg/issues/5623 > [2] - > https://github.com/apache/iceberg/issues/5803#issuecomment-1259759074 > [3] - https://github.com/apache/iceberg/pull/10935 >
