PutIcebergRecord

PutIcebergRecord Processor

类型全限定名：cn.org.acal.lynxus.processors.iceberg.PutIcebergRecord

所属 Bundle：cn.org.acal.lynxus:lynxus-iceberg-processors-nar:2.11.8

使用可配置的目录将记录存储在 Iceberg 表中，以管理Namespace和表。

下表中，加粗的属性为必填项；其余为可选项。表格同时标注默认值、是否支持表达式语言，以及是否为敏感属性（值会被加密）。

名称	可选值	描述
Iceberg Catalog	控制器服务 API： `IcebergCatalog` cn.org.acal.lynxus-lynxus-iceberg-service-api-nar-2.11.8	Iceberg 目录的提供商服务
Iceberg Writer	控制器服务 API： `IcebergWriter` cn.org.acal.lynxus-lynxus-iceberg-service-api-nar-2.11.8	为负责生成格式化冰山数据文件的 Iceberg Row Writer 提供服务
Record Reader	控制器服务 API： `RecordReaderFactory` cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8	传入FlowFile的Record Reader
Namespace		包含表的 Iceberg Namespace 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Table Name		冰山表名称支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）

名称	描述	自动终止
`failure`	FlowFiles 未传输到 Iceberg	否
`success`	FlowFiles 传输到 Iceberg	否

该组件不存储状态。

该组件不受限。

该组件要求有传入连接。