-
湖仓一体电商项目(十一):编写写入DWS层业务代码
DWS层主要是存放大宽表数据,此业务中主要是针对Kafka topic “KAFKA-DWD-BROWSE-LOG-TOPIC”中用户浏览商品日志数据关联HBa...
Lansonli 2023-01-02
456 0 0 -
大数据ClickHouse进阶(二):MergeTree表引擎
在所有的表引擎中,最为核心的当属MergeTree系列表引擎,这些表引擎拥有最为强大的性能和最广泛的使用场合。对于非MergeTree系列的其他引擎而言,主要用...
Lansonli 2023-01-02
467 0 0 -
湖仓一体电商项目(十六):业务实现之编写写入ODS层业务代码
由于本业务涉及到MySQL业务数据和用户日志数据,两类数据是分别采集存储在不同的Kafka Topic中的,所以这里写入ODS层代码由两个代码组成。
Lansonli 2023-01-02
445 0 0 -
湖仓一体电商项目(十七):业务实现之编写写入DIM层业务代码
DIM层业务代码与第一个业务处理Kafka topic “KAFKA-DIM-TOPIC” 数据到HBase代码完全一直,所以这里直接复用第一个业务中的DIM层...
Lansonli 2023-01-02
437 0 0 -
湖仓一体电商项目(二十二):实时任务执行流程
这里默认HDFS、Hive、HBase、Kafka环境已经准备,启动maxwell组件监控mysql业务库数据:
Lansonli 2023-01-02
448 0 0 -
Flink CDC 新一代数据集成框架
主要讲解了技术原理,入门与生产实践,主要功能:全增量一体化数据集成、实时数据入库入仓、最详细的教程。Flink CDC 是Apache Flink的一个重要组件...
小马哥学JAVA 2023-01-02
454 0 0 -
Flink CDC 新一代数据集成框架
主要讲解了技术原理,入门与生产实践,主要功能:全增量一体化数据集成、实时数据入库入仓、最详细的教程。Flink CDC 是Apache Flink的一个重要组件...
小马哥学JAVA 2023-01-02
453 0 0