一、需求分析与思路
支付宽表的目的,最主要的原因是支付表没有到订单明细,支付金额没有细分到商品上,没有办法统计商品级的支付状况。 所以本次宽表的核心就是要把支付表的信息与订单明细关联上。
解决方案有两个 ➢ 一个是把订单明细表(或者宽表)输出到 Hbase 上,在支付宽表计算时查询 Hbase,这相当于把订单明细作为一种维度进行管理。 ➢ 一个是用流的方式接收订单明细,然后用双流 join 方式进行合并。因为订单与支付产生有一定的时差。所以必须用 intervalJoin
来管理流的状态时间,保证当支付到达时订单明细还保存在状态中。