Lanson

V1

2022/10/26阅读:26主题:兰青

湖仓一体电商项目(十七):业务实现之编写写入DIM层业务代码

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

一、代码编写

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

二、代码测试

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

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

分类:

后端

标签:

大数据

作者介绍

Lanson
V1

CSDN大数据领域博客专家