UpdateSnowflakeIcebergDatabase 2025.5.31.15¶
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 explicitlyusing 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>] }
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 |
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. |