是否有一种机制可以在调用之间保留处理器状态

Is there a mechanism for preserving Processor state between calls

调用之间是否有 preserving/saving 处理器状态的机制? 特别是我想要一个可靠的机制来知道我的进程什么时候结束 运行,即使处理器,甚至 NiFi 本身已经重新启动。

(请不要给出hBase或文件系统之类的答案,我要找NiFi提供的东西,或者可以用NiFi提供的服务构建的东西)

目前没有开箱即用的功能可以在整个应用程序中为所有处理器自动捕获列出的信息。

有一些机制可以通过 ControllerServices(将这些视为 cross-cutting 关注点或方面的组件)在组件中实现此类功能,例如 DistributedMapCacheServer/Client or DistributedSetCacheServer/Client。

有些处理器以类似于您想要的功能的方式使用这些控制器服务,例如 DetectDuplicate or ListHDFS

这是目前的情况。下一个版本 (0.5.0) 的工作正在进行中,它将带来更多框架功能来完成此类任务,其工作在我们的 State Management Feature Proposal.

中进行了概述。

如果这些项目中的 none 非常符合您想要的功能,或者您有其他想法,我鼓励您通过我们的 mailing lists if you want to hash out your ideas and/or JIRA.

与社区分享它们