首先看一下整体流程,可以看到这里用的PutHbaseJson处理器,把数据导入到
hbase中的
注意这里也可以使用PutSql导入数据,通过phoenix的jdbc驱动,然后把数据利用PutSql处理器导入到
Hbase中,但是我这里的时候报错了,然后一直没解决,所以最后用了PutHbaseJson处理器,把数据存入到Hbase中去.
然后我们再来看首先我们给GenerateTableFetch处理器来配置一下数据库连接池
创建一个数据库连接池
起个名字,叫Postgresql-From的数据库连接池
jdbc:postgresql://172.19.126.123:5432/postgres?useUnicode=true&characterEncoding=utf8&useSSL=true&autoReconnect=true&reWriteBatchedInserts=true
org.postgresql.Driver
/opt/module/jars/postgresql-42.3.8.jar
postgres
123456