业务描述: 有N个商品类,对每个商品类下的订单进行报警判断。一个订单的报警判断需要依赖此商品类下之前所有订单累算的结果。
现在是这么实现的,从Source添加的数据中包含了所有商品类下的订单,所以我用keyBy()将订单按商品类划分,用keyedState保存这个商品类下订单的累算结果,然后flatMap()进行判断并输出报警的订单。
遇到的问题是,50%的订单来自A商品类,商品类B、C、D、E、F、G、H各占很少一部分。现在flatMap有两个并发,一个处理了商品类ABCD,另一个并发处理商品类EFGH。
请问怎么样做才能做到均衡这两个并发?例如一个只处理A,其他商品类在另一个并发处理。
(可能今天50%的订单是A,明天50%的订单是B)
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。