ontrigger-nifi自定义处理器的工作
共有1个答案
当您运行Maven构建以生成NAR文件时，将编译处理器的Java代码。代码不是由NiFi自己编译的。
然后，通过将NAR文件放置在lib目录中，将其部署到NiFi实例中，然后通过将其添加到画布中，在流中使用来自该NAR的组件。
一旦组件出现在画布上并被启动，就会根据调度策略调用onTrigger方法。
-
我试图加载一个自定义的NiFi处理器，但无法让NiFi加载所有的.nar依赖项，尽管尝试了各种pom.xml配置。我在SO上遇到过一些类似的问题，但还没有找到这个问题的答案。
-
我使用的是Nifi 0.4.1版本。我写自定义代码转换CSV到avro格式。我已经创建了类文件，并能够生成nar文件。将nar文件放置在lib目录中，并重新启动nifi服务器。 任何帮助都很感激.. 谢谢，
-
我正在研究创建一个自定义处理器从一个自定义源中摄取数据，那里没有现有的nifi处理器。 我一直试图理解Nifi组件如何工作的机制，并看到了一些关于如何创建自定义处理器的好文档，然而，我看不到任何关于管理偏移量的内容。假设我有一个运行1秒的处理器，但需要从某个任意偏移量继续进行处理，这可能会每秒钟产生结果，也可能不会产生结果。
-
我正在构建一个自定义处理器来处理流文件，为了处理流文件，我需要从我的本地文件系统读取CSV文件。我创建了一个proerty描述符CSV_PATH，如下所示 现在我想在配置处理器时获取在UI中设置的CSV_PATH属性的值。我无法获得CSV_PATH值。另外，如果我在代码中硬编码filepath，那么我仍然无法从本地文件系统读取CSV。
-
在1.12中引入之前，我已经编写了一个自定义处理器来处理多部分帖子。我拥有的处理器和nar可以正常工作，但是nar包引入了许多标准处理器的副本，其版本号与我的自定义处理器的版本号相匹配。 这是在我引入SSLContextService控制器之后开始发生的。添加控制器服务需要添加 根据apache nifi wiki上的指南，但是完整的nar似乎包含了标准nifi处理器的“2.1.1-Snapsho