本文主要是介绍[bigdata-028]apache nifi 从mysql导出数据到hbase,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
0.在hbase节点,启动thrift服务hbase-daemon.sh start thrift
1. 在本机启动nif
./bin/nifi.sh start
2. 在浏览器输入http://localhost:8080/nifi,看到nifi的界面
3. 拖一个processor ExecuteSQL到界面
3.1 在processor上点击右键,选择configure,点击第三个tab,也就是properties
3.2 在property列表,选择 database connection pooling service-->DBCPConnectionPool,然后再点击右侧的箭头,配置下一个选项,
3.3 于是到了Process Group Configuration页面,点击右侧“+”符号,添加一个mysql数据库的连接。
jdbc:mysql://192.168.20.175:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=true
com.mysql.jdbc.Driver
/home/xxxx/mysql-connector-java-5.1.39.jar
root
123456
3.4 然后,在回到ExecuteSQL的properties,设置SQL select query为 select * from user
3.5 设置Max Wait Time为10 seconds
4. 从mysql里出来的是avro
这篇关于[bigdata-028]apache nifi 从mysql导出数据到hbase的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!