湖仓一体电商项目(十七):业务实现之编写写入 DIM 层业务代码
业务实现之编写写入 DIM 层业务代码
一、代码编写
DIM 层业务代码与第一个业务处理 Kafka topic “KAFKA-DIM-TOPIC” 数据到 HBase 代码完全一直,所以这里直接复用第一个业务中的 DIM 层业务代码“DimDataToHBase.scala”即可。
二、代码测试
执行代码“DimDataToHBase.scala”之前首先需要启动 HDFS、HBase,代码中设置读取 Kafka 数据从头开始读取,然后执行代码,代码执行完成后可以进入 phoenix 中查看对应的结果:
复制代码
版权声明: 本文为 InfoQ 作者【Lansonli】的原创文章。
原文链接:【http://xie.infoq.cn/article/ae4fd65ab6527c8806d87fad2】。文章转载请联系作者。
评论