Modify data with DML statements
Stay organized with collections
Save and categorize content based on your preferences.
Modifying data lets you update, delete and merge records in your Apache Iceberg tables in the Lakehouse runtime catalog.
When BigQuery DML is enabled on your table, you can run standard DML statements from BigQuery alongside open source engines like Spark and Trino, achieving full write interoperability on a single copy of data stored in Cloud Storage.
Before you begin
-
Verify that billing is enabled for your Google Cloud project.
-
Enable the BigLake API.
Roles required to enable APIs
To enable APIs, you need the
serviceusage.services.enablepermission. If you created the project, then you likely already have this permission through the Owner role (roles/owner). Otherwise, you can get this permission through the Service Usage Admin role (roles/serviceusage.serviceUsageAdmin). Learn how to grant roles. - Set up the Lakehouse runtime catalog with the Apache Iceberg REST catalog endpoint.
Required roles
To get the permissions that you need to modify data in a table, ask your administrator to grant you the following IAM roles on your project and storage bucket:
-
Write table data in credential vending mode:
BigLake Editor (
roles/biglake.editor) - the project -
Write table data in non-credential vending mode:
- BigLake Editor (
roles/biglake.editor) - the project - Storage Object User (
roles/storage.objectUser) - the Cloud Storage bucket
- BigLake Editor (
For more information about granting roles, see Manage access to projects, folders, and organizations.
You might also be able to get the required permissions through custom roles or other predefined roles.
Table capabilities and support
When using tables in the Lakehouse runtime catalog, it's helpful to understand the different table types and their opt-in capabilities. To learn more about using Apache Iceberg tables specifically, see Overview of Apache Iceberg tables.
Supported Iceberg tables
Only Apache Iceberg V2 (GA) and V3 (Preview) tables are supported. Iceberg V1 tables aren't supported. To upgrade existing V1 tables, see Upgrade Iceberg V1 tables to V2.
Use table options (Preview)
You can opt in to use BigQuery managed capabilities, such as BigQuery Data Manipulation Language (DML) and automatic table management, by configuring specific table properties. These features are enabled in different ways depending on where the table is created:
- From BigQuery: BigQuery DML and automatic table management are enabled by default.
- From open source engines: To opt-in, you must explicitly configure table properties. See Configure table options for more information.
Update data
Update existing rows in the table:
Spark
ALTERTABLETABLE_NAMESETTBLPROPERTIES('gcp.biglake.bigquery-dml.enabled'=true);
UPDATETABLE_NAMESETdata='updated row'WHEREid=1;
Trino
ALTERTABLETABLE_NAMESETPROPERTIES"gcp.biglake.bigquery-dml.enabled"='true';
UPDATETABLE_NAMESETdata='updated row'WHEREid=1;
BigQuery
UPDATE`PROJECT_ID.CATALOG_ID.NAMESPACE.TABLE_NAME`
SETdata="updated row"
WHEREid=1;
Replace the following:
PROJECT_ID: your Google Cloud project ID.CATALOG_ID: your Lakehouse runtime catalog ID.NAMESPACE: your Iceberg namespace name.TABLE_NAME: the name of your Iceberg table.
Delete data
Delete specific rows from the table:
Spark
ALTERTABLETABLE_NAMESETTBLPROPERTIES('gcp.biglake.bigquery-dml.enabled'=true);
DELETEFROMTABLE_NAMEWHEREid=1;
Trino
ALTERTABLETABLE_NAMESETPROPERTIES"gcp.biglake.bigquery-dml.enabled"='true';
DELETEFROMTABLE_NAMEWHEREid=1;
BigQuery
DELETEFROM`PROJECT_ID.CATALOG_ID.NAMESPACE.TABLE_NAME`
WHEREid=1;
Merge data
Merge data from a source table into your target Iceberg table:
Spark
ALTERTABLETARGET_TABLESETTBLPROPERTIES('gcp.biglake.bigquery-dml.enabled'=true);
MERGEINTOTARGET_TABLEt
USINGSOURCE_TABLEs
ONt.id=s.id
WHENMATCHEDTHEN
UPDATESETt.data=s.data
WHENNOTMATCHEDTHEN
INSERT(id,data)VALUES(s.id,s.data);
Trino
ALTERTABLETARGET_TABLESETPROPERTIES"gcp.biglake.bigquery-dml.enabled"='true';
MERGEINTOTARGET_TABLEt
USINGSOURCE_TABLEs
ONt.id=s.id
WHENMATCHEDTHEN
UPDATESETt.data=s.data
WHENNOTMATCHEDTHEN
INSERT(id,data)VALUES(s.id,s.data);
BigQuery
MERGE`PROJECT_ID.CATALOG_ID.NAMESPACE.TARGET_TABLE`t
USING`PROJECT_ID.CATALOG_ID.NAMESPACE.SOURCE_TABLE`s
ONt.id=s.id
WHENMATCHEDTHEN
UPDATESETdata=s.data
WHENNOTMATCHEDTHEN
INSERT(id,data)VALUES(id,data);
What's next
- Learn how to query a table.
- Learn how to configure table options.