湖仓一体电商项目（十七）：业务实现之编写写入DIM层业务代码

​业务实现之编写写入DIM层业务代码

一、代码编写

DIM层业务代码与第一个业务处理Kafka topic “KAFKA-DIM-TOPIC” 数据到HBase代码完全一直，所以这里直接复用第一个业务中的DIM层业务代码“DimDataToHBase.scala”即可。

二、代码测试

执行代码“DimDataToHBase.scala”之前首先需要启动HDFS、HBase，代码中设置读取Kafka数据从头开始读取，然后执行代码，代码执行完成后可以进入phoenix中查看对应的结果：

代码语言：javascript复制

# 在node4节点上启动phoenix
[root@node4 ~]# cd /software/apache-phoenix-5.0.0-HBase-2.0-bin/bin
[root@node4 bin]# ./sqlline.py 

数据湖计算DLC数据湖

0 人点赞