minify - 从 nifi 带参数执行 java 程序

标签 minify hortonworks-data-platform apache-nifi hortonworks-sandbox

我想从 cassandra 数据库中获取一些术语,然后将它们作为参数发送给 java 程序,该程序将输出一些我需要保存在 cassandra 数据库中的数据。

nifi 是否可以实现这一点?如果可以,可以使用哪些处理器?特别是用于 java 程序的执行,因为我已经看到 cassandra 的处理器已经存在。

谢谢!

最佳答案

Apache NiFi 提供了许多用于运行自定义 Java 代码的选项:

  • 外部进程 - Apache NiFi 的 ExecuteProcessExecuteStreamCommand处理器可用于运行任何外部进程并将输出作为流文件内容返回。 ExecuteProcess 不传递输入流,其中 ExecuteStreamCommand 通过 stdin 流式传输输入流文件内容。两个处理器都接受使用 NiFi 表达式语言格式化的参数。这些处理器并不关心您的进程是否是 Java,它只是作为外部进程运行。这可能是运行代码最快、最简单的方法。
  • 自定义处理器 - 您还可以创建自定义处理器,以更加 NiFi 原生的方式运行 Java 代码。这需要一些额外的工作,但如果这是一个问题的话,将为大容量提供最佳性能。 NiFi Developer Guide可以提供帮助。
  • 脚本 - 第三种方法是使用 ExecuteScriptInvokeScriptedProcessor处理器来运行使用您的自定义 Java 代码的 Groovy 脚本。这是一个很好的方法来尝试将代码作为自定义 NiFi 处理器运行,而无需编写完整处理器实现的所有开销。

关于minify - 从 nifi 带参数执行 java 程序,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44005108/

相关文章:

hadoop - 在YARN中设置作业优先级

regex - 如何统计值在一行中出现的次数?

apache-nifi - 如何在 NiFi 表达式语言中使用正则表达式捕获组变量?

minify - Bower 和 Grunt 工作流程

tcp - 在运行Apache Spark Job时由对等方重置连接

javascript - 如何包含适当的 JavaScript 文件版本(缩小版与原始版)?

hadoop - 如何将加密数据写入HDFS

apache-nifi - NiFi fetchFile 处理器不允许动态属性

JavaScript 压缩器输出换行而不是分号 - 基于 Windows

css - W3 Total Cache 没有缩小只有几个 CSS