作品集
我的一些代表性作品
电商双速行为分析平台(BiSpeed-Ecom)
基于 Flink + PySpark 的实时+离线双引擎电商行为分析系统。采用 Lambda 架构,实时层通过 Flink DataStream API 实现滚动窗口 + TopN 计算,离线层通过 PySpark 完成数仓分层(ODS→DWD→DWS→ADS),最终经 Flask + ECharts 可视化大屏统一展示。
双引擎 实时+离线
Flink 1.17 实时计算
4层 数仓分层
3节点 集群规模
FlinkKafkaRedisMySQLPySparkFlaskEChartsScala