00:00
好,那接下来呢,我们要把这个内容转换为流。啊,那转化为硫的时候,大家想table,因为点。啊,那这个地方大家告诉我用pen string还是retra string?想一想。说一下这个理由对吧。啊,反正不会错。好,Retra的反应是不会错,这个倒没问题。
01:00
这个倒没问题啊,就是说如果能用aend的,那我也能用retra,但如果只能用retra,用reend就会报错。对吧,你是这样想的,反正不会错,对吧?啊,那实际上这里边a pen string就够了。那同学说不对呀,你这里面不做了聚合吗?做了聚合还能用这个aend吗?那我们想啊,我们是不是开窗聚合的。那为什么之前说做了聚合就不能用APA来,是因为对于相同的分组下,它是不是对数据要做修改呀,撤回老数据写入新数据吧,对吧,是这样的一个过程啊,所以呢,这边。但是这边没有问题。啊,这边是没有问题的,因为我们做了开窗。啊,做了开窗,那下一次聚合出来的就不是这个窗口了,跟它没什么关系了,对吧,跟它是没有关系的啊,就不会有问题对吧?好,那这个地方呢,我们就直接用reri流啊,Table传进来这个位置要一个class,之前我们用的是不是都是肉啊。
02:08
啊,用的肉这个呢,不用它,我们现在呢,用一个招聘啊,那我们这边要定一个招聘,招聘呢,在这边拿一下啊。实体表对吧,叫province states,叫province states OK。把这个拿过来,然后接下来呢,我把这个字段全部拿过来啊,有的东西我们可能做要要做一个修改。往那一放。对吧?呃,那这个字段名称我给他拿过来,哎,这里边还有一个GS对吧,S的话,最后我们可以加一下啊,这个没关系对吧,还有一个时间戳作为版本字段的,首先我们对比一下这个字段对不对啊,这个叫STT,注意一定要名字一样,顺序无所谓,因为根据这个名字来匹配的。然后。
03:00
Province ID,哎,我没放province ID对吧?行,那我们加一个这个地方呢,加一个province ID啊,创建表的时候在这边我复制一份。往这一放啊,这边呢,我们叫province ID。Pro ID呢用的是long类型,所以呢,我们改成对吧,好,那既然这边有了,那这边也要加一下对吧,我把它拿过来。再加一下。Province ID,然后呢,这边既然加了,那最后分组条件里边注意一定也要加,对吧,不要漏了,好,那我们要对比一下province ID,之前我们说了ID要的对吧,刚才写的时候忘了,然后name province name没问题,名字一样province code名字一样I so code名字一样31662 province31662扣的没问题,好,All the。Count,那这个地方呢,我没有写这个对吧?我叫out city,那它叫all count b,这个地方取的别名一定要跟我们。招聘当中一致,一定要跟招聘当中一致,因为这个时候呢,才可以在自动映射的时候能匹配上啊嗯,然后是一个。
04:09
All the amount all the amount,哎,我叫total amount不行对吧,我改个名字叫all the amount,我昨天都有了,然后还差一个什么SS呢,我们在查询的时候可以自己给一个吧,来把它拿过来啊,你自己给一个。然后呢,给一个TS。好,那我就用系统时间了啊,用系统时间了啊,这边我给它干掉对吧,我用一个系统时间来做这个TS啊,因为它是作为版本嘛,对吧,作为版本啊,所以说用系统时间没问题,假如说你这种挂掉了,我这个窗口重新计算了,重新计算用的时间肯定比上一次计算。时间要大对吧,就把上一次覆盖掉嘛,对吧,就是这个意思,所以它是作为一个版本存在的TS,呃,那我用系统时间,系统时间呢,这边有啊,也找一个函数就好了。啊,那我们找一个。
05:01
就用它呗,Unix time step对吧。他获取当前的时间用的是秒,用的是秒,那如果说咱们想用毫秒的话,那一个1000。对吧,用毫秒就这样去比一下就好了。有一个TS对吧,那这个就搞定了,这是我们自己给的数据,不需要非得在分组,也不需要做什么聚合。直接给的对吧,直接给的是没有关系的啊行,那这个字段呢就搞定了,注意啊,一定要最后你要转化为留之前的这张动态表,跟咱们的招聘这里面字段名字一定要都一样。一定要都一样,一定要对一下对吧,好这个搞定,搞定好之后呢,我们就可以用这个province。Plus,对吧,我们就得到了一个states data stream,那先呢,我们也不着急往里写,我们先呢打印,因为可能还有问题,因为这种字符串拼接啊,我其实也没底对吧,因为有时候也会出错,有时候也会出错啊,那我们就调一下啊,对吧。
06:06
来。把这个往那一放。来往这一放,我们先做一个打印,不要着急往那写,对吧,如果打印都打印不了。啊,对对,这个地方找错包了a provi。Province says。那我们留改一下啊,这一个product,这次一个province容易看错对吧?啊,这个感谢陈总提醒啊,要不然很明显就要搞一个错了。对吧,很明显就一个错了啊,就是里边数据看着不全啊,行,那这个就搞定province states,然后呢,Province states对吧?行,那这个没有问题啊呃,那接下来呢,我们做一个测试啊,这个呢,我们就做完了啊,将动态表转化为流给你打印啊。
我来说两句