AvroRecordSetWriter¶

描述¶

以二进制 Avro 格式写入 RecordSet 的内容。

标签¶

avro、record、recordset、result、row、serializer、set、writer

属性¶

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

显示名称	API 名称	默认值	允许值	描述
架构参考写入器 *	架构参考写入器			服务实现，负责使用架构参考信息编写 FlowFile 属性或内容标头
架构写入策略 *	架构写入策略	avro-embedded	嵌入 Avro 架构不写入架构设置“schema.name”属性设置“avro.schema”属性架构参考写入器	指定应如何将记录的架构添加到数据中。
缓存大小 *	cache-size	1000		指定应缓存多少架构
压缩格式 *	compression-format	NONE	BZIP2 DEFLATE NONE SNAPPY LZO	写入 Avro 文件时使用的压缩类型。默认为“None”。
编码器池大小 *	encoder-pool-size	32		Avro 写入器需要使用编码器。创建编码器的成本较高，不过创建后可以重复利用。此属性用于控制可被池化并重复使用的编码器的最大数量。该值设置过小可能会导致性能下降，而设置过高则可能会占用更多的堆。如果 Avro 写入器的架构写入策略配置为“嵌入 Avro 架构”，则将忽略此属性。
架构访问策略 *	schema-access-strategy	inherit-record-schema	继承记录架构使用“架构名称”属性使用“架构文本”属性	指定如何获取用于解读数据的架构。
架构分支	schema-branch			指定在“架构注册表”属性中查找架构时使用的分支名称。如果所选架构注册表不支持分支，则该值将被忽略。
架构缓存	schema-cache			指定要向其中添加记录架构的架构缓存，以便记录读取器可以快速查找架构。
架构名称	schema-name	${schema.name}		指定要在架构注册表属性中查找的架构的名称。
架构参考读取器 *	schema-reference-reader			服务实现，负责读取 FlowFile 属性或内容以确定架构参考标识符
架构注册表	schema-registry			指定用于架构注册表的控制器服务
架构文本	schema-text	${avro.schema}		Avro 格式架构的文本
架构版本	schema-version			指定要在架构注册表中查找的架构版本。如果未指定，则将检索架构的最新版本。

状态管理¶

此组件不存储状态。

受限¶

此组件不受限制。

系统资源注意事项¶

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