Hi yuxia, Thanks for the proposal! I think it'll be very useful for users in batch scenarios to cooperate with external systems.
For the flip I have two questions: 1. Is it a typo the default method 'default ScanPurpose getScanPurpose();' without implementation in interface ScanContext? 2. For stream users, what exceptions will be received for this unsupported operations? Best, Lincoln Lee yuxia <luoyu...@alumni.sjtu.edu.cn> 于2022年12月26日周一 20:24写道： > Hi, devs. > > I'd like to start a discussion about FLIP-282: Introduce Delete & Update > API[1]. > > Row-Level SQL Delete & Update are becoming more and more important in > modern big data workflow. The use cases include deleting a set of rows for > regulatory compliance, updating a set of rows for data correction, etc. > So, in this FLIP, I want to introduce Delete & Update API to Flink in > batch mode. With these interfaces, the external connectors will have > ability to delete & update existing data in the corresponding storages. > > Looking forwards to your feedback. > > [1]: > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=235838061 > > > Best regards, > Yuxia > >
