代码之家  ›  专栏  ›  技术社区  ›  Sateesh Telaprolu

nifi是否支持将单个流文件传输到处理器中的多个关系?

  •  3
  • Sateesh Telaprolu  · 技术社区  · 6 年前

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

    示例代码:

    session.transfer(flowFile, REL_SUCCESS_1);
    session.transfer(flowFile, REL_SUCCESS_2);
    
    1 回复  |  直到 6 年前
        1
  •  7
  •   daggett    6 年前

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

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

    创建流文件的完整克隆。

    内容和属性将相同。。。