UpdateSnowflakeIcebergDatabase 2025.5.31.15¶
捆绑包¶
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>] }
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
---|---|
添加列策略 |
当传入架构的列在现有表中不存在时使用的策略 |
更改列策略 |
当列在传入架构中与现有表中的数据类型不同时使用的策略 |
连接池 |
用于连接到 Snowflake 的连接池 |
所需架构 |
所需的架构/表定义 |
删除列策略 |
当现有表的列在传入架构中不存在时使用的策略 |
最大批处理大小 |
给定表在一次执行中可以处理的最大 FlowFiles 数量。 |
记录读取器 |
用于获取所需架构的记录读取器 |
架构名称 |
要更新的架构的名称 |
表元数据缓存到期时间 |
移除缓存条目的时间(秒) |
表名称 |
要更新的表的名称 |
表架构策略 |
指定如何获取所需的架构/表定义 |
使用表元数据缓存 |
是否缓存表的元数据,而不是直接从 Snowflake 读取 |
关系¶
名称 |
描述 |
---|---|
failure |
如果无法更新表,则传入的 FlowFile 将路由到此关系 |
illegal alteration |
如果更新需要进行配置为失败的更改,则传入的 FlowFile 将路由到此关系 |
success |
成功更新表后,则传入的 FlowFile 将路由到此关系 |
table not found |
如果指定的表不存在,则传入的 FlowFile 将路由到此关系。 |