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

标签

iceberg

输入要求

REQUIRED

支持敏感的动态属性

false

属性

属性

描述

添加列策略

当传入架构的列在现有表中不存在时使用的策略

更改列策略

当列在传入架构中与现有表中的数据类型不同时使用的策略

连接池

用于连接到 Snowflake 的连接池

所需架构

所需的架构/表定义

删除列策略

当现有表的列在传入架构中不存在时使用的策略

最大批处理大小

给定表在一次执行中可以处理的最大 FlowFiles 数量。

记录读取器

用于获取所需架构的记录读取器

架构名称

要更新的架构的名称

表元数据缓存到期时间

移除缓存条目的时间(秒)

表名称

要更新的表的名称

表架构策略

指定如何获取所需的架构/表定义

使用表元数据缓存

是否缓存表的元数据,而不是直接从 Snowflake 读取

关系

名称

描述

failure

如果无法更新表,则传入的 FlowFile 将路由到此关系

illegal alteration

如果更新需要进行配置为失败的更改,则传入的 FlowFile 将路由到此关系

success

成功更新表后,则传入的 FlowFile 将路由到此关系

table not found

如果指定的表不存在,则传入的 FlowFile 将路由到此关系。

语言: 中文