Re: [I] Support general DELETE statement on primary key table [fluss]

["Zhuoxi2000 (via GitHub)" <gi...@apache.org>]

Zhuoxi2000 commented on issue #1594:
URL: https://github.com/apache/fluss/issues/1594#issuecomment-5304558026

   I’d like to take this one.
   
   My understanding is that DELETE on a primary-key table currently only supports point deletes when the condition matches the full primary key, while the general case was left out of #1201.
   
   Following @luoyuxia’s note that this should go through `applyRowLevelDelete`, I’m planning to mirror the UPDATE path: implement `FlinkTableSink#applyRowLevelDelete` so the planner scans the matching rows and the sink emits deletes by primary key.
   
   I’ll keep the scope to the sink-side implementation, ITCases for non-PK predicates, partial-PK predicates, and partitioned PK tables, plus updating the docs to remove the current limitation.
   
   Could a committer assign this to me?
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@fluss.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org