ExtractRecordSchema

文档中心 › 组件索引 › ExtractRecordSchema

ExtractRecordSchema Processor

类型全限定名:cn.org.acal.lynxus.processors.standard.ExtractRecordSchema

所属 Bundle:cn.org.acal.lynxus:lynxus-standard-nar:2.11.8

描述

使用提供的Record Reader从 FlowFile 中提取记录模式并将其写入“avro.schema”属性。

标签

recordgenericschemajsoncsvavrofreeformtextxml

属性

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

名称默认值可选值描述
Record Reader控制器服务 API:
RecordReaderFactory
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8
指定用于读取传入数据的 Controller Service
Schema Cache Size10指定要缓存的 Schema 数量。此值应反映传入 FlowFile 中可能存在的不同 Schema 的预期数量。这确保了更高效的 Schema 检索,从而提高处理器性能。

关系 (Relationships)

名称描述自动终止
failure如果无法从配置的输入格式中提取 FlowFile 的记录 Schema,FlowFile 将被路由到此关系。否
success成功提取记录模式的 FlowFile 将被路由到此关系否

写入的 FlowFile 属性

名称描述
record.error.message该属性在失败时提供阅读器遇到的错误消息。
avro.schema此属性提供使用提供的 RecordReader 从输入 FlowFile 中提取的架构。

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。