UpdateSnowflakeIcebergDatabase 2025.10.2.19¶

Bundle¶

com.snowflake.openflow.runtime | runtime-snowflake-processors-nar

Description¶

Updates the definition of a Snowflake Iceberg table. A target schema can be inferred from a RecordReader or defined explicitly using the format below: { “columns”: [ { “name”: “<column name>”, “type”: “<iceberg data type>” }, … ] } where <iceberg data type> can be one of: - primitive iceberg type (“string”, “int”, “boolean”,…) - decimal with given precision and scale (“decimal(P,S)”) - {“type”: “list”, “element”: <iceberg data type>} - {“type”: “map”, “key”: <iceberg data type>, “value”: <iceberg data type>} - {“type”: “struct”, “fields”:[<list of struct fields>] }

Tags¶

iceberg

Input Requirement¶

REQUIRED

Supports Sensitive Dynamic Properties¶

false

Properties¶

Property	Description
Add Column Strategy	The strategy to use when the incoming schema has a column that is not present in the existing table
Alter Column Strategy	The strategy to use when a column has different data type in the incoming schema from the existing table
Alter Column Type Strategy	The strategy to use when the existing table has a column with a different type than the incoming schema.
Connection Pool	The connection pool to use to connect to Snowflake
Desired Schema	The desired schema / table definition
Drop Column Strategy	The strategy to use when the existing table has a column that is not present in the incoming schema
Max Batch Size	The maximum number of FlowFiles that can be processed in a single execution for a given table.
Record Reader	Record Reader to use for obtaining the desired schema
Schema Name	The name of the schema to update
Table Metadata Cache Expiration Time	The time in seconds after which the cache entry will be removed
Table Name	The name of the table to update
Table Schema Strategy	Specifies how to obtain the desired schema / table definition
Use Table Metadata Cache	Whether to cache table’s metadata instead of reading it directly from Snowflake

Relationships¶

Name	Description
failure	The incoming FlowFile is routed to this relationship if the table cannot be updated
illegal alteration	The incoming FlowFile is routed to this relationship if the update requires an alteration that is configured to fail
success	The incoming FlowFile is routed to this relationship after the table has been updated successfully
table not found	The incoming FlowFile is routed to this relationship if the specified table does not exist.

Writes attributes¶

Name	Description
schema.hash	A hexadecimal-encoded SHA-256 hash of the final table schema after all updates have been completed.