JsonRecordSetWriter

描述

以 JSON 数组或每行一个 JSON 对象的形式写入 RecordSet 的结果如果使用数组输出，则即使 RecordSet 由单行组成，也会写成包含单个元素的数组。如果使用“每个对象一行”输出，JSON 对象将无法进行美观打印。

标签

json、record、recordset、resultset、row、serialize、writer

属性

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

显示名称

API 名称

默认值

允许值

描述

允许科学记数法 *

允许科学记数法

false

  • true

  • false

指定在写入数字时是否应使用科学记数法

日期格式

日期格式

指定读取/写入“Date”字段时使用的格式。如果未指定，则将假定“Date”字段为自纪元（1970 年 1 月 1 日午夜 GMT）以来的毫秒数。如果指定，则该值必须与 Java java.time.format.DateTimeFormatter 格式相匹配（例如，MM/dd/yyyy 表示两位数的月份，然后是两位数的日期、四位数的年份，全部由“/”字符分隔，如 01/01/2017）。

美观打印 JSON *

美观打印 JSON

false

  • true

  • false

指定是否应对 JSON 进行美观打印

架构参考写入器 *

架构参考写入器

服务实现，负责使用架构参考信息编写 FlowFile 属性或内容标头

架构写入策略 *

架构写入策略

no-schema

  • 不写入架构

  • 设置“schema.name”属性

  • 设置“avro.schema”属性

  • 架构参考写入器

指定应如何将记录的架构添加到数据中。

时间格式

时间格式

指定读取/写入“Time”字段时使用的格式。如果未指定，则将假定“Time”字段为自纪元（1970 年 1 月 1 日午夜 GMT）以来的毫秒数。如果指定，则该值必须与 Java java.time.format.DateTimeFormatter 格式相匹配（例如，HH:mm:ss 表示 24 小时格式的两位小时数、两位分钟数和两位秒数，全部由“:”字符分隔，如 18:04:15）。

时间戳格式

时间戳格式

指定读取/写入“Timestamp”字段时使用的格式。如果未指定，则将假定“Timestamp”字段为自纪元（1970 年 1 月 1 日午夜 GMT）以来的毫秒数。如果指定，则该值必须与 Java java.time.format.DateTimeFormatter 格式相匹配（例如，MM/dd/yyyy HH:mm:ss 表示两位数的月份，然后是两位数的日期、四位数的年份，全部由“/”字符分隔；然后依次是 24 小时格式的两位小时数、两位分钟数和两位秒数，全部由“:”字符分隔，如 01/01/2017 18:04:15）。

压缩格式 *

compression-format

无

  • 无

  • gzip

  • bzip2

  • xz-lzma2

  • snappy

  • snappy framed

  • zstd

要使用的压缩格式。有效值为：GZIP、BZIP2、ZSTD、XZ-LZMA2、LZMA、Snappy 和 Snappy Framed

压缩级别 *

compression-level

1

  • 0

  • 1

  • 2

  • 3

  • 4

  • 5

  • 6

  • 7

  • 8

  • 9

要使用的压缩级别；这仅在使用 GZIP 压缩时有效。值越低，处理速度越快，但压缩率越低；值为 0 表示没有压缩，只是存档

输出分组 *

output-grouping

output-array

  • 数组

  • 每个对象一行

指定写入者应如何输出 JSON 记录（例如，作为数组或每行一个对象）请注意，如果选择“每个对象一行”，则美观打印 JSON 必须为 false。

架构访问策略 *

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

指定要在架构注册表中查找的架构版本。如果未指定，则将检索架构的最新版本。

抑制 Null 值 *

suppress-nulls

never-suppress

  • 永不抑制

  • 始终抑制

  • 抑制缺失值

指定写入器应如何处理 Null 字段

状态管理

此组件不存储状态。

受限

此组件不受限制。

系统资源注意事项

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

语言: 中文