Open Table Iceberg - Execute

This Snap has at most one document input view. When connected, each input document triggers one execution of the SQL statement. Field values from the input document can be referenced in the SQL expression using $field notation.

• Mapper
• Copy

For SELECT statements and other SQL that returns rows, the Snap emits one document per result row.

For DDL and DML that returns no rows, the Snap emits one status document per execution: {"status": "success", "message": "SQL statement executed successfully", "sqlStatement": "..."}.

• Mapper
• Copy

Label

Required. Specify a unique name for the Snap. Modify this to be more appropriate, especially if more than one of the same Snaps is in the pipeline.

Default value: Open Table Iceberg - Execute

Example: Iceberg Create Orders Table

Specify the Spark SQL statement to execute against the Iceberg catalog. The field supports expressions, allowing you to reference upstream document fields using $field notation to build dynamic statements.

Supported statement types include SELECT, CREATE TABLE, INSERT INTO, ALTER TABLE, DROP TABLE, MERGE INTO, and other Spark SQL with Iceberg extensions.

Default value: None

CREATE TABLE IF NOT EXISTS db.orders (
  order_id BIGINT,
  customer_id BIGINT,
  order_date DATE,
  total DECIMAL(10,2)
) USING iceberg;

Snap execution

Default value: Execute only

Example: Validate & Execute