apache / apache/fluss

Support general DELETE statement on primary key table

Open
#1,594 4 comments 1 reaction 0 assignees View on GitHub
component=kv good first issue
Dominant language
Java
Stars
2.1k
Forks
625
Avg merge
3d 14h
Merged PRs (30d)
97

Description

### Search before asking

- [x] I searched in the [issues](https://github.com/apache/fluss/issues) and found nothing similar.

### Motivation

See the discussion https://github.com/apache/fluss/pull/1201#discussion_r2168287356

Currently, we only support DELETE statement on primary key table with equal condition on primary key. This is very limited and we should support general DELETE statement like how we implement UPDATE statement via `org.apache.fluss.flink.sink.FlinkTableSink#applyRowLevelUpdate`.

### Solution

_No response_

### Anything else?

_No response_

### Willingness to contribute

- [ ] I'm willing to submit a PR!

Contributor guide

No contributing guide indexed for this repository

Research direction

Start by reading org.apache.fluss.flink.sink.FlinkTableSink#applyRowLevelUpdate and the linked discussion in pull request 1201, then trace the current DELETE handling for primary-key tables. Done means DELETE statements support conditions beyond equality on the primary key, consistently with the existing row-level update approach.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
databases, stream-processing
Issue type
Feature
Difficulty
4/5
Estimated time
3-5 days
Activity status
Quiet
Clarity
Mostly clear
Newbie friendliness
50/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.