是否有在调用之间保留/保存处理器状态的机制？特别是我想要一个可靠的机制来知道我的进程上次运行的时间，即使处理器，甚至 NiFi 本身已经重新启动。
（请不要给出hBase或文件系统之类的答案。我正在寻找NiFi提供的东西，或者可以使用NiFi提供的服务构建的东西）
问问题
257 次
1 回答
3
目前没有开箱即用的功能可以在整个应用程序中为所有处理器单方面自动捕获列出的信息。
有一些机制提供了通过 ControllerServices（将这些视为横切关注点或方面的组件）在组件中完成此类功能的能力，例如DistributedMapCacheServer /Client 或DistributedSetCacheServer /Client。
有些处理器以类似于您所需功能的方式使用这些控制器服务，例如DetectDuplicate或ListHDFS。
这就是目前的情况。下一个版本 (0.5.0) 的工作正在进行中，它带来了更多的框架功能来完成这些任务，我们的状态管理功能提案中概述了它的工作。
如果这些项目都不符合您想要的功能，或者您有其他想法，我鼓励您通过我们的邮件列表与社区分享它们，如果您想提出您的想法和/或JIRA。
于 2016-01-01T01:19:44.713 回答