67.腾讯云EMR-实时数仓搭建-DWD层-交易域订单事实表原创

好，那接下来呢，我们去。搞定我们DW底层最后一张表叫下单事务事实表，对吧？那这张表呢，是我们整个DW层最复杂的一个需求，因为它涉及到的表比较多，下单那首先呢，有自己的这个订单表，然后有订单明细表，同时还有订单明细活动关联表，还有订单明细优惠券关联表，呃，同时呢，我们还要关联这个字典表，获取我们的订单状态啊，所以呢，这个需求比较麻烦，就在于它的表比较多，但是呢，我们之前讲了两表座椅对吧，那五张表其实也一样的。啊，只不过说多写几个状语而已，但这里面有一个点需要大家注意，在我们下订单的时候，并不是我们所有的订单都会参与的活动，或者说参与了这个。领券对吧，那也就是说当我们把订单和订单明细表关联好以后，跟这两张表的一个关联呢，那要使用到我们之前所提到的这个left。

Join没有问题吧，啊，要使用我们的level join好，那这块呢，嗯，其实就没有什么其他特别复杂的东西了，因为level join这个前置的知识点已经给大家介绍过了啊，那无非就是说在之前的基础上，我们要过滤出。五张表，然后呢，做一个join啊，那这个只要把需求搞定了，其他的也就不难了，对吧？那这是前置的一个知识点，我们已经给大家介绍过了，所以就不做介绍了，呃，图解当中呢，就是这五张表做一个关联嘛，也没有什么太多可说的内容啊呃，那我们就直接做到这个事情啊，只不过说这边要注意一下，呃，当我们使用left drawing之后。大家之前看到。当我们。A表来了一条数据对吧？啊，B表来数据之后呢，A表先来数据，那么先输出一个A，那然后B表来数据之后呢，它会把这条数据撤回。然后重新写一个AB出去，对吧？啊，这两个是加，所以它在这里边呢，形成的是一个撤回流，之前我们是用回流进行打印的，那对于我们之前的卡夫卡呢，撤回流是。

不行的，它会直接报错啊，它不允许接入这个撤回流数据，所以呢，我们要用一个up的更新流的一个方式啊，那这地方呢，工具类里边其实我们已经添加了这个方法，诶在这块给大家去使用到的好吧，呃，那这个就没有什么其他问题了啊，这个工具类呢，我们已经导过了，所以我们就直接把主程序拿过来。在这个位置。啊，呃，那么。把这个拿过来啊，这两个包我就不走了吧，我就直接从这个地方开始扫啊。把这个替换掉啊，因为这两个包呢，反正我们要重新导入一下啊，还有一个是买SQL去读取我们字典表的啊。呃。这边等会我们要注掉，所以就无所谓了啊，那第一部分还是一样的，我带来看一下第一部分获取这个执行环境。

呃，第二部分呢，设置这个TTL时间，因为涉及到流的一个影啊，第三块呢，是状态后端的一个设置啊，这个时区呢，我们还是保留着，呃，第一步获取topic DB，然后过滤出订单明细表，订单明细表呢，直接表明all the detail，然后呢音色的数据啊，然后第二个呢，获取订单表all in音色的数据就好了。那接下来呢，是这个活动。活动表啊，读取活动表银色的，然后呢，优惠券，诶优惠券之后呢，我们获取字典表，然后把这五张表做一个关联啊，做一个状语，那其中呢，跟我们的这个活动表，还有这个。优惠券表做的是left join对吧？好，那之后呢，把它写出去啊。那这边呢，是阿色的卡夫卡，好，那看一下前面哪块啊，这个地方呢，我们就不要了。因为我们已经把那块出示掉了，对吧，这个多余的依赖呢，我们可以给它干掉，找到爆给它干掉，好，那这个需求呢，也就搞定了啊，无非就是说大家在工作的时候，可能这里的字段要比我们更多，可能稍微的要复杂一些啊，除此之外呢，没有什么其他的内容了，好吧。