NiFi处理会话迁移功能怎么使用

问题描述

我正在尝试在读取流文件的同时输出流文件。 （它会在完成读取文件的一部分而不是整个文件后立即输出）

但是，似乎ProcessSession要求所有流文件都已提交，然后目标处理器才能读取它。否则，可以选择将其迁移到另一个处理器。

如何使用迁移功能？更具体地说，在哪里可以获取“ newOwner”值？

或者如果有人对我的原始问题有任何想法？

这是ProcessSession代码：github.com/apache/nifi/blob/master/nifi-api/src/main/java/org/apache/nifi/processor/ProcessSession.java

我非常感谢使用迁移的任何示例处理器代码。

思路：

检查AbstractProcessor来源

您可以覆盖该方法

public final void onTrigger(final ProcessContext context, 
                            final ProcessSessionFactory sessionFactory)

存储sessionFactory链接以及您需要创建新会话时：

ProcessSession newSession = sessionFactory.createSession();

作为示例，检查使用MergeContent调用Bin ...的处理器[C0

相信朋友们都看清楚了这篇“NiFi处理会话迁移功能怎么使用”文章吧！在我们爱站技术频道网站有很多不同类型的技术文章，如果你喜欢的话可以随时来关注收藏。