apache/fluss

Support general DELETE statement on primary key table

Open

#1594 aperta il 26 ago 2025

Vedi su GitHub
 (3 commenti) (1 reazione) (0 assegnatari)Java (570 fork)auto 404
component=kvgood first issue

Metriche repository

Star
 (1979 star)
Metriche merge PR
 (Metriche PR in attesa)

Descrizione

Search before asking

  • I searched in the 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!

Guida contributor

Direzione di ricerca
Implementare un'istruzione DELETE generale per le tabelle con chiave primaria estendendo la logica applyRowLevelUpdate di FlinkTableSink per gestire le operazioni DELETE, seguendo l'approccio nella discussione PR di riferimento.
Tech stack
java
Dominio
backenddatabase
Tipo issue
Funzionalità
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
3
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
1-2 giorni
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
Attiva
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
Abbastanza chiara
Prerequisiti
JavaSQLFlink
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
25