版本 | 任务 | 时间 |
---|---|---|
V1.0 | 过滤用户的消费金额,过滤用户购买的商品数量 | 2023-08-12 |
V2.0 | 计算每个用户累计消费的金额 | 2023-08-17 |
两个任务并行处理
- 过滤用户的消费金额
- 过滤用户购买的商品数量
userPortrait
文件夹下CDUserPurchaseAnalysis.java
文件
计算每个用户累计消费的金额
AccumulateAccountBitMap
文件——使用BitMap
数据类型作为状态保存AccumulateAccountSet
使用HashSet
数据类型作为状态保存
- 依赖编译设置:pom.xml
<mainClass>设置为相应的主函数路径</mainClass>
比如com.sunhb.flinklearn.filter.AccumulateAccountSet</mainClass>
- 打包:maven package 将程序打包成
jar
运行文件 - 运行:
./bin/flink run xxxxx.jar
- WebUI查看flink运行过程中内存使用情况