温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
好,那接下来呢,我们要用弗林CDC去消费配置表,并形成我们的一个。广播流对吧,那首先这边呢,肯定是flink CDC来做一个消费,好,那你比方说我们先写上,那这边呢是my circle s。点的对吧,那返回值呢,我们还是用string类型好了。接下来啊,最后呢,会调用这个build对吧,那中间呢,我们加上house name哈102。点3306对吧,然后user name。他说。啊,这个搞定,然后接下来呢,我们有一个database list,就是说我们监控的库明是谁,以及table list表明是谁,对吧?啊,那注意啊,这个地方那个库名我知道呀,就是G末杠210325杠和另一个呗,对吧?哎,这个并不是啊,因为这个是属于我们的业务库,一般账号后台是不允许你在这边再去进行建表的啊,所以呢,我们放另外一个库,等会呢,我们把这个库去创建一下,我们放在实时的,诶我们自己大数据的这个库,当然买这服务我们就没搞两个了啊,但是生产环境当中买S服务也得是另外一个是你大数据里边安装的买S服务啊,做的事情好,至于表呢,我们就叫table process。
01:40
啊,表的一个处理对吧?啊配置信息叫他好,那接下来启动模式,那我们做初始化的就好了啊做初始化了,因为全表都读过来嘛,第一次启动的时候是不是要把全表数据读过来呀,对吧,做初始化好,那接下来呢,还有这个反学化的这个东西一定要要一下啊,啊还是一样的customer。
02:02
那这一堆东西呢,就准备好了,我们就看到二加V得到我们的s function,然后接下来我们要去因为点AS,把这个s function呢跟进去啊,得到了一个。Page信息流。对吧,啊配置信息流,那这个呢,我们叫table。Process,然后str的一个接下来的问题是我们要把它做成一个广播流,那这个操作方式大家还记得吗?怎么把它变成一个广播流啊?其实也比较简单对吧,那就把它倒过来调用我们的broadcast,注意这个呢要用第一个。啊,要用第一个,第一个返回值呢,是一个广播流,看见没叫broadcast stream,而第二个叫广播,广播的意思指的是将我们接下来这个流里边数据在自己这个流里边进行广播。
03:02
啊,那这个是要用到一个广播状态来看啊。它里边要一个map state describe,也就是说要一个有一个map state,好,那到这块为止呢,我们就不太能写的下去了,好把这个呢放进来,对吧,看得到了一个broadca string,那到这块位置,接下来我们要去想一下啊,想几件事情啊,第一我们的表其实还没建立。对吧,我们得去想表第二件事情,什么事呢。这个里边它是不是还要一个KV类型啊,那我们这个地方KV类型是不是也要根据表里的信息来做这个事情。对吧,我们要根据表的信息来做这样的事情啊,所以呢,接下来写到这块为止,我就写不下去了,因为这块没法定了,对吧,到底这个K做什么样子,Value又是什么样子啊,所以接下来我们要去讨论这个表应该怎么去建立啊,写到这块写不下去的对吧?啊,所以呢,把它。
我来说两句