This command is used to delete records from a Hudi table.
DELETE from tableIdentifier [ WHERE boolExpression]
Parameter |
Description |
---|---|
tableIdentifier |
Name of the Hudi table to delete records. |
boolExpression |
Filtering conditions for deleting records. |
delete from h0 where column1 = 'country';
delete from h0 where column1 IN ('country1', 'country2');
delete from h0 where column1 IN (select column11 from sourceTable2);
delete from h0 where column1 IN (select column11 from sourceTable2 where column1 = 'USA');
delete from h0;
You can view the result in driver logs or on the client.