AvroReader¶

描述¶

解析 Avro 数据并将每条 Avro 记录作为单独的 Record 对象返回。Avro 数据可能包含架构本身，也可以通过“架构访问策略”属性提供的方法之一对架构进行外部化并进行访问。

avro、comma、delimited、parse、reader、record、row、separated、values

下表列出了各项属性，其中带星号 (*) 的为必需属性。其他属性视为可选属性。该表还指出了所有默认值以及属性是否支持 NiFi 表达式语言。

显示名称	API 名称	默认值	允许值	描述
缓存大小 *	cache-size	1000		指定应缓存多少架构
架构访问策略 *	schema-access-strategy	embedded-avro-schema	使用“架构名称”属性使用“架构文本”属性架构参考读取器使用嵌入式 Avro 架构	指定如何获取用于解读数据的架构。
架构分支	schema-branch			指定在“架构注册表”属性中查找架构时使用的分支名称。如果所选架构注册表不支持分支，则该值将被忽略。
架构名称	schema-name	${schema.name}		指定要在架构注册表属性中查找的架构的名称。
架构参考读取器 *	schema-reference-reader			服务实现，负责读取 FlowFile 属性或内容以确定架构参考标识符
架构注册表	schema-registry			指定用于架构注册表的控制器服务
架构文本	schema-text	${avro.schema}		Avro 格式架构的文本
架构版本	schema-version			指定要在架构注册表中查找的架构版本。如果未指定，则将检索架构的最新版本。

此组件不存储状态。

此组件不受限制。

此组件未指定系统资源注意事项。