ExtractRecordSchema Processor
描述
使用提供的Record Reader从 FlowFile 中提取记录模式并将其写入“avro.schema”属性。
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| Record Reader | | 控制器服务 API:RecordReaderFactorycn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 指定用于读取传入数据的 Controller Service |
| Schema Cache Size | 10 | 指定要缓存的 Schema 数量。此值应反映传入 FlowFile 中可能存在的不同 Schema 的预期数量。这确保了更高效的 Schema 检索,从而提高处理器性能。 |
关系 (Relationships)
| 名称 | 描述 | 自动终止 |
|---|---|---|
failure | 如果无法从配置的输入格式中提取 FlowFile 的记录 Schema,FlowFile 将被路由到此关系。 | 否 |
success | 成功提取记录模式的 FlowFile 将被路由到此关系 | 否 |
写入的 FlowFile 属性
| 名称 | 描述 |
|---|---|
record.error.message | 该属性在失败时提供阅读器遇到的错误消息。 |
avro.schema | 此属性提供使用提供的 RecordReader 从输入 FlowFile 中提取的架构。 |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
输入要求
该组件要求有传入连接。