- 该项目主要用于搭建基于大数据框架的用户行为日志收集、存储、分析平台;
- flink数据清洗任务、统计任务、数据转发任务、数据存储任务
- 离线统计任务:通过任务调度框架(Dolphin Scheduler)进行离线数据的统计
- 数据分析平台搭建
- Sink服务
- 后台查询服务
- 数据初始化脚本
- prometheus + grafana监控上报处理个数和处理速率
用户埋点行为日志分析平台,项目主要用于搭建基于Flink、Apache Doris、Redis和MySQL等中间件的用户行为日志收集、存储、分析平台,支持用户自定义查询条件
JavaGPL-3.0