00:00
好,那么接下来呢,这个是刚才我们测的这个叫。对,加swim这种方式对吧?那接下来呢,我们还有继续啊,那此时呢,那个CDC第一块这块内容呢,就全部搞定了,大家测试的时候可以按照这个打包对吧?呃,启动我们的集群,然后呢,这个表我在文档当中做的表不一定跟这个一样啊,对吧,你要随便挑一张表都行嘛,无所谓对吧,你做测试啊,然后呢,去保存c point,同时用杠S的方式。来重启我们的任务对吧,做这事好,那其实在官方当中呢,它不光提供了data STEM,它还提供了flink circle的方式,他还提供了弗Li s的方式,那我们来可以给大家看一下啊,在这边,呃,哎,这个还有问题对吧?那我们退回来这个地方也能看得到啊,弗link s的方式在这。对吧,我们要去创建一张表,在我们文档当中之后呢,可以去查询啊,做这个事情好,那现在呢这样,嗯,那第一步我们先导入依赖弗林S的话,我们肯定要有这个。
01:08
实行计划table plan对吧?啊,那那个调节器可以不出,因为这里边其实包含了有这个调节器的啊,那第一个先把这个依赖导进来啊,泡沫当中,然后呢,导入我们的依赖。好,那这个呢就搞定了,我们可以检查一下在这个main这啊,然后呢,Li CDC,嗯,Depends。Flink Java clients。诶,没有引进来是吗?行,那我们刷新一下,刷新一下,哎,这就有了,注意啊,一定要看到这个东西才可以行,那接下来呢,我们写代码。啊,这个第二个呢,是林格CDC位啊。
02:01
With so。用so的方式来使用我们的CDC,那么第一步还是一样的PSM。第一步获取执行环境,只不过说这个时候执行环境呢,要多一个对吧,要获取table inv啊第二个呃,见表。啊,地理方式见表。那这样来查询。查询数据,那我们就查询全表数据就好了,然后接下来呢,我们将数据。转换为流啊,应该是应该不叫数据啊,我们叫动态表吧,更好一点对吧,因为我们查询数据得到的是一个动态表,那我们要转化为流做打印对吧?好,那这边呢,我们就启动任务啊,那我们转化为流打印叫启动,如果说我们拿到是table result,可以直接调用print,对吧?好,第一个执行获取执行环境,那这个很简单,Stream。
03:07
Execution environment。Get。好,那CTRL加V得到一个因V啊,然后呢,因为点S我们的度。那接下来还有一个table in啊,String table environment.create,把in呢扔进去,CTRL加V,得到我们的table env,好,那第二个就是见表呢,对吧?到这边来我们点ex circle见表语句,那这表语句的话,我们可以改一改拿过来对吧。呃,在这我们把这个拿过来改一改分号不要分号不要。其实主要的下面这些参数,主要的要的就是这些东西啊。来到这个地方来往这一放啊杠N,我全部去掉CTRL加R。CTRLR,把这个杠N我们全部替换成一个空格replace号,好,那这样呢,好看一点,呃,那create table,那这个呢,我们这于表明其实无所谓,你想叫什么叫什么,那我们就叫my solo呗,对吧?好,那接下来第一个ad,呃,In类型nono没有问题啊,假如说你不放心,我们可以用思接受。
04:21
对吧,防止这个地方这个数据我们还用这张表啊,第二个叫TM name对吧,那我们写一下TM name啊下划线,嗯,它呢是四类型没有问题,第三个叫logo URL,注意就下划线啊,那第三个呢叫logo_URL也是4G类型,那这个就搞定了,这个呢我们就没有第四个。列了,那这个逗号要干掉,因为你干掉一个列,所以呢这个逗号干掉,接下来我们看,呃,连接器是MYSOCDC,注意连接器的啊,就跟大家之前学习弗Li so的时候fair卡夫卡一个道理,对吧?连接器的种类在这声明,然后接下来呢,我们连的机器名是哈杜102,端口3306,用户名我是root,然后密码123456,接下来database STEM,我们是J杠。
05:15
210325杠,然后呢,Link对吧,这个库,然后表呢叫base trademark。啊,这个刚才也说了共鸣表明对吧,共鸣表明那大家想一下啊,问大家一下,哎,在data塔string当中,我们可以监控这个。多个表。也就是说我只写库名的时候,他。就把该库底下所有的表都会监控过来,那么如这个里边我他这一行我不写。那这个逗号就不能要了,对吧,这个逗号啊,那是不是代表的监控的是当前这个库底下所有的表呢,大家想一下能不能这样玩。
06:03
他能不能监控多库多表呢?能不能呢?对了,不行不行,大家的理由很充分啊,因为你想想看,上面呢,是一个见表语句,那如果说这边这个库底下有十张表,ABCDEF,对吧,一堆表,那到底你你怎么可能呢?你给这十张表写一个统一的建表语句吗?是不是不太现实啊,对吧?所以那你就知道了弗link circle和雷达streamam之间的一个区别了。
07:02
对吧,它这个区别了,Data stream可以监控多库多表,而flink circle每次只能监控。A张表啊,它只能做单表的解构,这个一定要注意一下对吧?好,那还有关于data stream当中我们写的,你比方说这个叫start mode。Option点对吧,这种方式啊,那initial这种方式,那它在哪呢?它也是通过这种参数,但是这个啊,其实我刚才就想打开,诶这个这时候网速还行。我们等它打开啊,等会儿它其实参数的配置信息在这个文档当中啊,在这个文档当中能看到啊,行也就通过这个参数配进来的,就是还是一样的加参数,然后你配置初始化latest思对吧,这样的方式啊,是这个意思能听懂吧。啊,也是通过参数传进来的,不像之前apim嘛,调方法就行了,现在呢,界面语句你得通过再加参数这种方式来做才可以啊行,那接下来呢,我们查询数据啊,查询数据呢,我们就拿着table,因为点circle query啊这样比方说这个表呢,我们就select的心。
08:11
From叫my circle below这张表对吧,我们就查询这张表的全面数据啊,看下V得到一个表明,那接下来呢,表转化为硫table in may.to那比方说我们。害怕他做一些什么其他的事情,我们可以叫一个retra,对吧,因为如果你是追加流,Retra一定能用,就retra更通用一点,对吧,你是追加流也能用,Check的撤回流也能用,所以呢,我们用这种方式啊,那就是table,第二个类型,我们可以用一个招聘,招聘呢,你就包含这三个参数,ID TM name logo URL就可以了,对吧,那没有招聘的时候,我们用一个通用的类型叫肉。点class啊,通用的类型好,那这样的话我们得到了一个流。
09:00
Retra STEM,接下来呢,Retra stem.print做一个打印对吧?好,接下来启动v.cute。然后呢,我们也给他一个。名字叫flink circle with啊flink CDC为circle这个异常呢,测试环境嘛,所以我们就抛一下啊抛一下,但是如果说你要对它实现断点续传一样的,你要开启这个车point的,最后呢,可以做s point的做这些事情,对吧,要做这样的事情才可以啊行,那这块呢,我们就写完了。啊,我们就写完了对吧,写完之后呢,我们可以做一个测试啊。来运行一下,我们也可以看一下,我们并没有传start options,我们看一下它默认的到底是什么东西,对吧。哎,这边开启了,开启之后呢,我们点到这边来啊。它这个参数在这啊,连接器的参数对吧,你要用Li circle,它如果说你想要指定它的一个mode,看scan.start up.mode哎,默认的是什么。
10:09
Initial,但是这个应该是指的2.0啊,但没关系,我们看一下这个地方,咱们用的是1.2,也就是说它的参数你可以在这里边去找到啊,你都是一样的,通过那个呃单引号,然后呢,等于什么的方式来指令的啊,来指定的是这个意思啊。好,那我们看一下这个。结果。哎,有同学看这个东西不爽吗?是不是有同学看着也不爽,之前我在咱们班逛的时候,有个同学问到我了,他说怎么把这个去掉,就是依赖冲突了,对吧?我要干掉一个依赖。干掉一个依赖其实可以啊,你就是把它排除掉exclusive就好了,对吧。嗯。但是这个其实没什么影响啊,完全没有影响好,那默认的刚才我们看到它是不是这个初始化呀。
11:05
默认的是初始化吧,对吧,默认的是初始化,所以在这个当中呢,我们看到诶,他把前11条数据给我们干什么。打印了是不是啊,给我们打印了啊这样的东西好,那接下来呢,比方说我再来增加我还是做这个三个事情,看能不能做到这个事情啊。嗯,其实也不用测了吧,大家下去自己测一下,这个我就不给他测了啊,就是可以的,那连到冰道的最新的位置了嘛,对吧,接下来我就不测了啊,这个就不浪费时间。你自己下去还是测曾山?改三个对吧。下。
我来说两句