flink 结合canal统计订单gmv

[王飞]

hi 你好
    需要用flink 解析mysql的binlog 统计订单表  产品维度的gmv，
    但是一个insert的binlog 会出现同时购买多个订单 会出现一个集合的订单集合 但是我想统计订单里面产品维度的gmv，如下图
    返回的是一个list的订单集合，但是我想取每个订单里面的产品id进行维度统计 ，请问flink 有什么算子 可以把一个list数据的流数据 变成多条流
谢谢