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