ForkEnrichment
描述:
该处理器与JoinEnrichment处理器一起使用，负责添加JoinEnrichment处理器执行其功能所必需的属性。每个传入的FlowFile都将被克隆。原始的FlowFile将添加适当的属性，然后被转移到“original”关系中。克隆将添加适当的属性，然后路由到“enrichment”关系。有关这些处理器如何协同工作以及如何通过使用这些处理器在NiFi中执行enrichment任务的更多信息，请参阅JoinEnrichment处理器的文档(特别是它的附加细节)。
标签:
fork, join, enrich, record
参数:
该组件没有提供任何参数
连线:
| 名字 | 描述 |
|---|---|
| enrichment | 在添加适当的属性(比如enrichment标识的属性)之后，传入FlowFile的克隆将被路由到此关系。 |
| original | 在添加适当的属性之后，传入的FlowFile将被路由到此关系。 |
读取属性:
未提供。
写入属性:
| 名字 | 描述 |
|---|---|
| enrichment.group.id | 用于将“original”流文件与“enrichment”流文件关联的组ID。 |
| enrichment.role | 用于标记准备在enrichment逻辑里使用时的角色。值范围：ORIGINAL或ENRICHMENT。 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
未提供。