如何使用NiFi进程会话迁移功能？
如何使用NiFi进程会话迁移功能？
提问于 2020-01-03 03:41:32
我试图在读取流文件的同时输出流文件。(它在读取完文件的一部分而不是整个文件后立即输出)
但是，ProcessSession似乎要求在目标处理器可以读取所有流文件之前提交它。否则，可以选择将其迁移到另一个处理器。
如何使用迁移功能？更具体地说，我从哪里获得“newOwner”值？
或者有没有人对我原来的问题有什么想法？
下面是ProcessSession代码：github.com/apache/nifi/blob/master/nifi-api/src/main/java/org/apache/nifi/processor/ProcessSession.java
我非常感谢任何使用迁移的示例处理器代码。
回答 1
Stack Overflow用户
发布于 2020-01-03 07:59:24
检查AbstractProcessor源代码
您可以重写该方法
public final void onTrigger(final ProcessContext context,
final ProcessSessionFactory sessionFactory)当您需要创建新会话时，请存储sessionFactory链接：
ProcessSession newSession = sessionFactory.createSession();例如，检查使用调用session.migrate的Bin的处理器MergeContent ...
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/59569088
复制相关文章
相似问题
腾讯云开发者
