For Iceberg, delete duplication rows within the table

[zhengxingmao]

For Iceberg connector,how can we use one delete statement support remove duplication items within the table?

create table a (a int,bname int);
insert into a values (1,1),(2,2),(3,3),(4,4);
insert into a values (1,1),(2,2),(3,3),(4,4);
delete from a where b in (select b from (select b, row_number() over (partition by bname) as r from a )t where r>1 );  --this will delete all rows

Excepted :just delete the duplicated rows
Simply like sql server does.https://learn.microsoft.com/en-us/troubleshoot/sql/database-design/remove-duplicate-rows-sql-server-tab

[liabozarth]

+1

[YuriyGavrilov]

+1

[d4r3topk]

+1