ForkEnrichment 2025.5.31.15

捆绑包

org.apache.nifi | nifi-standard-nar

描述

该处理器与 JoinEnrichment 处理器配合使用,负责添加 JoinEnrichment 处理器执行其功能所需的属性。每个传入的 FlowFile 都将被克隆。原始 FlowFile 将添加相应的属性,然后传送到“original”关系。克隆将添加相应的属性,然后将路由到“enrichment”关系。有关这些处理器如何协同工作,以及如何在 NiFi 中使用这些处理器执行富化任务,请参阅 JoinEnrichment 处理器的文档(尤其是其“附加详细信息”部分)。

标签

enrich、fork、join、record

输入要求

REQUIRED

支持敏感的动态属性

false

关系

名称

描述

enrichment

添加相应的属性后,传入 FlowFile 的克隆将路由到此关系。

original

添加相应的属性后,传入的 FlowFile 将路由到此关系。

写入属性

名称

描述

enrichment.group.id

组 ID,用于将“original”FlowFile 与“enrichment”FlowFile 相关联。

enrichment.role

用于丰富信息的角色。该值将是 ORIGINAL 或 ENRICHMENT 之一。

另请参阅

语言: 中文