在Processor中搜索ExecuteSQLRecord

1.创建Database Connection Pool
2.创建JsonRecordSetWriter
3.配置SQL select query

select Host,User,authentication_string from mysql.user;

在Database Connection Pool中选择DBCPConnectionPool

1.Database Connection URL: jdbc:mysql://hostname:3306/druid
2.Database Driver Class Name: com.mysql.jdbc.Driver
3.Database User: username
4.Database Password: password

在Processor中搜索ConvertAvroToJSON

在Processor中搜索SplitJson

在Processor中搜索PutHBaseJSON

1.HBase Client Service： 选择匹配版本的HBaseClient
2.Table Name： 配置入库HBase表名
3.Row Identifier Field Name： 配置RowKey值
4.Column Family: 配置列簇

在Processor中搜索HBase_1_1_2_ClientService

1.Zookeeper Quorum: hostname1:2181,hostname2:2181,hostname3:2181
2.Zookeeper Client Port: 2181
3.Zookeeper ZNode Parent: /hbase

可以点击选择单个Processor启动，也可以在空白处点击流程启动

select * from druid.druid_datasource;

scan ‘druid.druid_datasource‘,{LIMIT=>10}

## 创建表空间
create_namespace ‘druid‘

## 查看表空间
list_namespace_tables ‘druid‘

## 创建表
create ‘druid.druid_datasource‘,‘cf1‘

## 查看表数据
scan ‘druid.druid_datasource‘,{LIMIT=>10}

将mysql驱动包放到nifi按照目录的lib中，重启nifi；如图中无需配置：Database Driver Location(s)项

如图配置：Database Driver Location(s)项，则驱动包可放在任何可访问的地址，无需重启nifi