Apache nifi的processor开发过程
Apache NiFi 是一个易于使用、功能强大而且可靠的数据处理和分发系统。Apache NiFi 是为数据流设计。它支持高度可配置的指示图的数据路由、转换和系统中介逻辑。nifi可以自己开发扩展插件processor,下面介绍processor的开发过程。
方法/步骤1 创建工程
(01)环境准备,需要安装jdk和maven。通过命令来检查jdkhemaven是否已经安装。
(02)开始创建processor工程。创建新的目录,并在目录下执行mvn archetype:generate。根据界面提示输入相应的版本和工程信息。命令执行完成后,就会生成nifi processor工程文件。
方法/步骤2 编写第一个processor
(01)工程生成后,在源码中可以找到一个默认的,可修改此文件来编写自己的第一个processor。
(02)为我的processor添加描述信息,属性,relation已经编写初始化函数。如下图所示:
(03)编写onTrigger函数。也是最重要的函数。这个函数来实现主要的功能。此函数主要分为以下几个内容:读取FlowFile,获取属性设置,写FlowFile提交到Relation。
方法/步骤3 编译并部署
(01)编译,在工程目录下执行mvn install命令。执行成功后,会生成文件。例如我的文件名称为为:。这个文件就是我们要部署的文件
(02)把放到nifi安装目录下的lib目录下。重新启动nifi服务。
(03)在nifi的界面上就可以看到自己编写的第一个processor了。
-
CentOS7关闭防火墙和SELinux
本文主要讲述了如何在CentOS7上临时关闭防火墙、永久关闭防火墙、临时关闭SELinux和永久关闭SELinux的方法。出自openstackblog。防火墙(firewalld)(01)临时关闭防火墙systemctlstopfirewalld(02)永久防火墙开机自启动systemctldisablefirewalld(03)临时打开防火墙syst...
-
教大家如何快速下载QQ群,超大群文件?
一般在QQ群里边下载文件比较慢且容易出错,给大家讲一种简单快速下载QQ群的,文件。速度快且文件不出错。操作方法(01)登录QQ号,打开QQ群。一般我们都是用这种方法下载。直接在QQ群里边下,这种方法慢且文件容易出错。(02)现说一下快速下载QQ群,超大群文件,先搜一下QQ群空间...
-
iOS7越狱后怎么恢复
iOS7越狱可能会出现各种各样的原因,白苹果、系统bug、无法识别手机助手等各种故障,这些问题都会让我们想将越狱后的iOS7恢复到原始状态。那么,我们该如何恢复越狱后的iOS7系统呢?iOS7越狱后恢复方法(01)首先,第一步要做的是下载固件包,在本经验页面底部【参考资料】内...
-
报名“天天特价”通过率高的技巧?
相信很多开网店的朋友都是知道天天特价的,因为报名天天特价,不能能引来很高的店铺流量,而且还能带起你店铺的成交,更能带动店内其他商品的成交,对于星级卖家店铺来说,这无疑是个巨大的诱惑和吸引力,正是因为这样,报名的商家更是成千上万,那么怎么样才能报名成功呢,下面小...