温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
那么接下来我们就实际动手试一下,让大家看一下这个效果,那我分为两种方式,第一种方式就是用普通的Spark代码,我们去做一个写入,第二种方式是使用德尔塔streamer工具,所以怎么去指定并发啊,那我们先看一下这种方式啊,你我们前面介绍,你可以用share去写DF,可以写Spark circle,也可以用idea工程去编码,对吧?啊,都可以啊,那现在为了方呃,当当然circle方式没有啊,这边主要是用data frame,难道就是share跟写写代码?好,那现在为了方便,咱们就用share呗,那我先从前面找到咱们这个share启动命令啊,我也拷过来吧,省得大家呃不好去。拷贝啊,嗯。这我想想啊,启动一个渲染吧,好吧,然后我放在这里。
01:08
好,这边文档调整一下,让大家看起来更舒服一点啊,这个标题也不要了,那第一步我们先启动线,我把命令拷过来,我们来执行啊。好,让他慢慢执行吧,接下来看一下咱们的这个线里面要写什么,首先是导入相关依赖,然后呢,就是我们前面用到的那个例子啊,那个出行数据,那这个代码跟前面是一模一样的,就包括用它的数据生成器去生成数据啊,形成一个DF,再去write到这张表,这就是我们前面操作过的那个代码一样啊,只不过在这里我加了一些参数啊,我们指定的地方就在这里option啊,然后呢,你看并要开要使用,呃,乐观并发控制呢,首先模式要指定,第二个要失败的时候策略为lazy,第3PROVIDE为我演示的是主keepper啊,那既然是主keepper,就要指定它的URL端口,还有它的锁。
02:12
锁名啊,还有它的路径,在主keep中的路径,这几个参数,那其他都没变啊,其他代码就跟前面那个SPA海穴那那里的案例是一样的,那废话少说,你直接把整个代码给拷贝过来啊,拷贝过来去执行,那么在它执行完之前,因为它执行完锁就释放了嘛,执行完之前我们去主keeper里面去看看我们指定的这个节点有没有生成,有没有生成对应的这个node啊,叫multi right test。那么然后再看里面在这个节点里面有没有这个T啊,有没有这个T行,那我们快速看一下呗啊。你要把主基本先启动啊。那我这边快速的先连一下啊JK。
03:07
好,诶,大家看到现在多了一个节点叫什么。Multi right test,然后赶紧看,要不然执行完就没了啊,诶完了别耽搁玩了,你看这里面是不是有一个什么test table。对吧,啊。这个呢,就是我们那再过一会儿等他这边跑完了啊,一会儿等他这边跑完了,我们再来看的话就没了啊。好,你看现在我们再来看这个目录下面,它已经没有了,对不对啊,已经没有了,那再看一下最外层的这个还在不在啊,还在,但是一会儿应该也会释放掉啊,不是这个锁已经没了对吧?啊,这个就是我们给大家演示啊,要所以你要看要看的及时。
我来说两句