MAPREDUCE服务 MRS-场景说明:场景说明

时间:2024-06-19 16:04:40

场景说明

假定某个业务Kafka每30秒就会收到5个用户的消费记录。Hbase的table1表存储用户历史消费的金额信息。

现table1表有10条记录,表示有用户名分别为1-10的用户,用户的历史消费金额初始化都是0元。

基于某些业务要求,开发的Spark应用程序实现如下功能:

实时累加计算用户的消费金额信息:即用户总消费金额=用户的消费金额(kafka数据) + 用户历史消费金额(table1表的值),更新到table1表。

support.huaweicloud.com/devg-mrs/mrs_06_0198.html