ExtractRecordSchema 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-standard-nar
描述¶
使用提供的记录读取器从 FlowFile 中提取记录架构并将其写入到 avro.schema 属性。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
cache-size |
指定要缓存的架构的数量。该值应反映可能位于传入 FlowFiles 的不同架构的预期数量。这样可以确保更有效地检索架构，从而提高处理器性能。 |
record-reader |
指定用于读取传入数据的控制器服务 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果无法从配置的输入格式中提取 FlowFile 的记录架构，则 FlowFile 将路由到此关系 |
success |
从中成功提取记录架构的 FlowFiles 将会路由到此关系 |
写入属性¶
名称 |
描述 |
|---|---|
record.error.message |
此属性提供了操作失败时读取器遇到的错误消息。 |
avro.schema |
此属性提供了使用提供的 RecordReader 从输入 FlowFile 中提取的架构。 |