我正在探索将 单个 Flowfile 传输到我的自定义处理器 中的两个或多个关系的选项,我没有在文档中找到任何帮助, NIFI 是否支持此功能?

示例代码:

session.transfer(flowFile, REL_SUCCESS_1);
session.transfer(flowFile, REL_SUCCESS_2);

最佳答案

您可以使用 session.clone() 方法:

FlowFile flowFile2 = session.clone(flowFile);
session.transfer(flowFile, REL_SUCCESS_1);
session.transfer(flowFile2, REL_SUCCESS_2);

创建流文件的完整克隆。

内容和属性将相同...

关于minify - nifi 是否支持将单个流文件传输到处理器中的多个关系?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/49607157/

10-12 00:13