00:00
咱们现在呢,来看一下啊,现在启动的东西,那目前呢,咱们订单订单明细对吧,这都起着呢,这些不用管它,咱们再把我这个order外是不是起一下就可以了,对吧?来,那咱现在呢,把这些东西给起一下。切完之后呢,这个报了一个错是吧。没输出是吧,那咱来看输出一下,呃,在这里边呢,我去对吧,把它做一个抽取对吧,做一个抽取,然后这个抽取呢,我看一看这个叫什么名字合适啊,这个叫order we,然后呢,在咱们这里是吧?然后呢,咱们那个order wide,然后呢,Li stream,然后接下来咱们现在呢,在这是吧,把它打印输出一下啊把打印输出一下来在这里咱们呢,来打印输出是吧?来看一看它的效果啊,来看它的效果是吧。
01:13
一般如果你要挺不住的话,就是idea就是挺不住了,对吧,就别的PP机什么的没关系,Idea就挺不住了,对吧?Idea挺不住的话,大家这个知道吧,就是在咱们那个ID安装目录下面,它不有一个我们修改内存的一个大小那个嘛,对吧,你可以把它改一改,对吧?你做过这个操作吗?应该有一个说什么option的文件对不对,对吧,那个对吧?呃,这个东西没做过,没关系,到网上一搜一大把对吧,各种改的,然后接下来呢,咱们现在呢,来去在这执行一下对吧?来执行一下,看一看啥样是不是。0510。啊来吧,那么咱这个数据呢,那有了对吧?那数据有了,呃,那么咱数据有了之后呢,那把这个呢,停一下对吧,停一下,停一下之后咱们再稍微做个验证吧,同学们对吧?然们看一看,我现在呢,把这个CTRLC拿过来,然后接下来呢,在这里CTRLV对吧?然后咱们现在看一看啊同学们,呃,来到哪呢?来到我们现在这个商品里边啊来到咱们这个把这订单我把这都关掉了,全部关掉到多少存,然后来到哪来到订单里边对吧?那么现在一共多少订单呢?现在一共是15订单,然后进来看到订单明细啊订单明细,然后在订单明细找谁呢?找咱们现在多个订单的对吧,其中看这个多一点的这3765是不是还可以啊对吧?3765这个呢,其实还可以对吧,那么咱们当前3765呢,一共是三个是吧,那你在这里来CTRLF对吧,然后接下来找谁呢?找3765,找365,那么咱。
02:58
现在呢,这里一共有三条对吧,这个数据,然后接下来那么咱们得看一看啊,那么它的一个实付分摊金额对吧?在哪呢?咱们来到我们现在呢,这个啊,这个这这个样运类里边对吧?然后找到我这个实付分担金融对吧,这个时候呢,就这是几个金额,然后在实部首单之前在咱们省份对吧,前面是傅首单啊来呗,咱们找在这里对吧,找谁呢?找咱们那个省份前面是候首单对吧,然后这块呢,是不是食物分担金额呀,对吧,这个省份这是候首单,然后这个呢,是食物负担金额,然后第一个474.39对吧,这一个474.39对吧,然后接下来那么除了这个之外呢,那么再往下对吧,在这。
03:51
省份对吧?拿这个拿过来对吧?拿过来这是第二个,那么第三个呢,在咱们这里还有一个对吧,449.52对吧,449.52是吧?好了,那么咱们现在呢,拿到这么三个值对吧?我一看尾数好像应该差不多是不是啊,一看尾数好像就跟个整数对不对?那么它们几个相加应该等于谁呢?同学们,它们几个相加应该等于谁啊,等于咱们实际花多少钱呗,对吧,这谁呢?咱们来到我们的order in for里边,然后看谁是不是它呀,对吧?那么实际花多少钱是不是咱现在7331啊,一样吗?同学们。
04:36
啊,咱差不多是不是没关系,这个结果不重要,就是差一块两块的,你把代码写完就行对吧?对项目不行啊,实际生产环境不行,但如果说你在练习的时候说老师我现在代码这个起来了,但是我就没有看到运营结果,我这机器顶不住了,不重要,同学们啊吧,就这个时候你允许你机器扛不住对吧,但是呢,这个代码今天代码你得给我写出来,对吧,好了,我现在把今天东西呢,稍微给大家总结一下啊,稍微给大家总结一下,没事的时候呢,对吧,这个这个图啊也画了画了啊这个图呢也画了画了对吧,咱们现在目前对吧,同学们咱们现在目前呢,那应该是今天主要所做的就是什么呢?就是把我们现在订单和订单明细对吧,他们两个形成宽表数据又写回到了我的卡夫卡对吧,然后接下来咱们通过一个文SPA stream程序对吧,然后呢,去读取我们现在卡卡这个数据,而且注意咱们现在读取的时候不是读一个主题,是从两个主题,然后。
05:36
两个流了,把这两个流呢,做了一个合并,对吧?那么这个叫什么叫双流join,那么双流join能直接读过去join了呢,肯定不行,对吧,因为咱们没有办法保证,那么咱们这两个数据是不是在同一个采集周期里边,对吧?所以说呢,那么要想解决这问题的话,两种方式,第一个缓存对吧,如果有兴趣的话,需有余力的情况下,把那缓存的时间呢,那也看一看,那么第二种方式呢,那么就是我们现在是不是划窗了,但是划窗的话,它可能会有重复数据,咱们得对重复数据做一个去重啊对,通过这个red,对这重复数据呢,做为去重,说老师我不用red,我就自己filter行不行,可以啊对吧?哎,可以对吧,然后接下来呢,咱们现在把这个处理完之后呢,那我们去做一个实步分摊,关于实步分摊的一个思路,同学们,我希望大家能够把这个东西是吧,给我这个自己理出来。
06:30
就这个东西,其实大家想一想,我这写代码的时候呀,这个代码其实不难,同学们就别别看咱们现在这里边这个这这个老师说写奏和代码,在其实同学们这里边代码其实呢不难对,这里的代码不难对,但前提是什么?前提是你得把这个思路给理顺了,如果说同学们你对咱们这个思路如果不理解的话,你光去看代码这个东西是比较痛苦的,对吧?还有一个东西你比较痛苦,就假如说如果你们在咱们离线那块,你对他们几个这这个单词,他们之间关系比什么含义,你要不理解的话,你现在看也很痛苦是吧?但如果说你在离线的时候,你把这些关系弄明白的话,其实这块呢,我觉得理解起来应该是比较容易的啊,应该是比较容易的是吧,呃,今天的任务呢,大概就这些对吧,大这些明天看什么呢?明天明天我去看你们师傅分担的代码怎么样。
07:21
明天休息,我我我们明天我们昨天刚休息完吗?是行吧,这个尽量做对吧,尽量做对吧,明天呢,看什么不重要对吧,明天我主要给你答疑啊,明天主要给答疑。
我来说两句