JoltTransformRecord 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-jolt-nar
描述¶
对 FlowFile 有效负载中的每条记录应用 JOLT 规范。使用转换后的内容创建了新的 FlowFile，并路由到“success”关系。如果转换失败，则原始 FlowFile 将路由到 failure 关系
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
自定义模块目录 |
以逗号分隔的文件和/或目录路径列表，这些文件和/或目录包含自定义转换的模块（不包含在 NiFi 的类路径中）。 |
自定义转换类名 |
用于自定义转换的完全限定类名 |
Jolt 规范 |
JSON 数据转换的 Jolt 规范。此属性的值可以是 Jolt 规范的文本或包含 Jolt 规范的文件路径。必须设置“Jolt 规范”，否则如果选择 Jolt 排序转换，则忽略该值。 |
Jolt 转换 |
指定应与提供的规范一起使用的 Jolt 转换。 |
转换缓存大小 |
编译 Jolt 转换可能相当昂贵。理想情况下，这项操作只需执行一次。但是，如果在转换中使用表达式语言，我们可能需要为每个 FlowFile 创建一个新的转换。此值用于控制我们在内存中所缓存转换的数量，从而避免每次都必须编译转换。 |
jolt-record-record-reader |
指定用于解析传入数据和确定数据架构的控制器服务。 |
jolt-record-record-writer |
指定用于写出记录的控制器服务 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果由于任何原因（例如，无法解析 FlowFile 记录）导致 FlowFile 处理失败，则会将其路由到此关系 |
original |
经过转换的原始 FlowFile。如果 FlowFile 处理失败，则不会向该关系发送任何内容 |
success |
包含转换后内容 FlowFile 将路由到此关系 |
写入属性¶
名称 |
描述 |
|---|---|
record.count |
传出 FlowFile 中的记录数 |
mime.type |
已配置的记录写入器指示的 MIME 类型是合适的 |