MapReduce服务 MRS-场景说明:场景说明
场景说明
假定某个业务Kafka每30秒就会收到5个用户的消费记录。Hbase的table1表存储用户历史消费的金额信息。
现table1表有10条记录,表示有用户名分别为1-10的用户,用户的历史消费金额初始化都是0元。
基于某些业务要求,开发的Spark应用程序实现如下功能:
实时累加计算用户的消费金额信息:即用户总消费金额=用户的消费金额(kafka数据) + 用户历史消费金额(table1表的值),更新到table1表。
检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
假定某个业务Kafka每30秒就会收到5个用户的消费记录。Hbase的table1表存储用户历史消费的金额信息。
现table1表有10条记录,表示有用户名分别为1-10的用户,用户的历史消费金额初始化都是0元。
基于某些业务要求,开发的Spark应用程序实现如下功能:
实时累加计算用户的消费金额信息:即用户总消费金额=用户的消费金额(kafka数据) + 用户历史消费金额(table1表的值),更新到table1表。