UpdateSnowflakeIcebergDatabase 2025.10.9.21¶

捆绑包¶

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

描述¶

更新 Snowflake Iceberg 表的定义。目标架构可以通过 RecordReader 推断出来，也可以使用以下格式显式定义：{ "columns": [ { "name": "<column name>", "type": "<iceberg data type>" }, ... ] }其中 <iceberg data type> 可以是以下各项之一：- 原始 iceberg 类型 ("string", "int", "boolean",...)- 具有给定精度和小数位数的十进制数 ("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

属性¶

属性	描述
添加列策略	当传入架构的列在现有表中不存在时使用的策略
更改列策略	当列在传入架构中与现有表中的数据类型不同时使用的策略
更改列类型策略	当现有表的列类型与传入架构不同时应使用的策略。
连接池	用于连接到 Snowflake 的连接池
所需架构	所需的架构/表定义
删除列策略	当现有表的列在传入架构中不存在时使用的策略
最大批处理大小	给定表在一次执行中可以处理的最大 FlowFiles 数量。
记录读取器	用于获取所需架构的记录读取器
架构名称	要更新的架构的名称
表元数据缓存到期时间	移除缓存条目的时间（秒）
表名称	要更新的表的名称
表架构策略	指定如何获取所需的架构/表定义
使用表元数据缓存	是否缓存表的元数据，而不是直接从 Snowflake 读取

关系¶

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

写入属性¶

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