UpdateSnowflakeIcebergDatabase 2025.10.2.19¶

捆绑包¶

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

描述¶

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>] }

标签¶

iceberg

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
添加列策略	当传入架构的列在现有表中不存在时使用的策略
更改列策略	当列在传入架构中与现有表中的数据类型不同时使用的策略
Alter Column Type Strategy	The strategy to use when the existing table has a column with a different type than the incoming schema.
连接池	用于连接到 Snowflake 的连接池
所需架构	所需的架构/表定义
删除列策略	当现有表的列在传入架构中不存在时使用的策略
最大批处理大小	给定表在一次执行中可以处理的最大 FlowFiles 数量。
记录读取器	用于获取所需架构的记录读取器
架构名称	要更新的架构的名称
表元数据缓存到期时间	移除缓存条目的时间（秒）
表名称	要更新的表的名称
表架构策略	指定如何获取所需的架构/表定义
使用表元数据缓存	是否缓存表的元数据，而不是直接从 Snowflake 读取

关系¶

名称	描述
failure	如果无法更新表，则传入的 FlowFile 将路由到此关系
illegal alteration	如果更新需要进行配置为失败的更改，则传入的 FlowFile 将路由到此关系
success	成功更新表后，则传入的 FlowFile 将路由到此关系
table not found	如果指定的表不存在，则传入的 FlowFile 将路由到此关系。

写入属性¶

名称	描述
schema.hash	最终表架构在完成所有更新后生成的十六进制编码的 SHA-256 哈希值。