00:00
那最后呢,我们看一下通过STEMAPI的方式开发一个搜索应用啊,怎么。来了解一下它怎么来进一步提高我们开发效率,那首先我们导入弗link circle相关的一些依赖啊。来泡门键,呃。到这里。好浸泡的。那这边导入的主要有什么呢?你看一个planner啊,要指定为我们一般都是用的blink对吧?Blink,然后后面几个无关紧要,一个是CSV格式的支持,一个是Jason格式的支持啊,看你有没有用到了啊,没用到你不倒也行,不倒也行。那接下来我们用他的API的话,我拷贝一个吧。啊,也不用拷贝啊,只能自己写了啊,我们叫STEM叉CC。
01:03
DEMO。VM。好,那第一步还是创建一个环境,那这个环境怎么来呢?另一个table啊,Contest con。啊env conig,大家注意选择什么间差的包下面的,那它同样要传两个参数,一个是XX,这个就是main方法的参数,第二一个一样的,我们要单独再指定一些,呃,环境变量环境参数啊,可以去指定,那我们说一般在配置文件就写好了啊,那这边就得到一个。表环境的配置文件,接下来是一个表的上下文啊,同样导包,注意是STEM差里面的啊,差里面就是把这个配置传进来啊,Table。
02:00
我们就得到了一个表的上下文环境。那接下来我们以前在代码里面开发circle,是不是要什么circle啊,对吧,然后拼接拼接拼接可能呃,你写的什么,呃,That,比如说ID name啊,什么ts from,然后再来个with。对吧,啊某某表,然后位置里面又写一堆参数是不是啊,这种写法是不是,嗯。太死了,不灵活,而且在代码里面写死了,对吧,要一改太不方便了,那如果我有多个作业啊,多个入口类都需要用到同一个连接啊,比如说都是同样要消费卡一个,那你是不是要重复很多遍啊,不方便啊,那API给我们提供了什么方式呢?哎,那就要涉及到第二种配置文件circle.ya。点进来在这里我们写什么,写circle啊,写circle那么一样的啊,注意缩进,你不要说我这边这么写啊,那不好啊,要注意缩进那第一个呃,相当于说起一个标签名啊,First无所谓,你叫一叫二叫A叫二都可以,然后冒号啊,然后呢,空格加一个什么呢,竖线。
03:19
那如果这是一串吧。啊,相当于说有三句circle对吧,那么如果你有。像有的人觉得不方便了,我一个标签包含的要跑这几个circle没错,那如果我再有一个类,我要执行的是另一些circle怎么办啊?那很简单,你再来一个啊,比如说你叫。Second。对吧,竖线啊,你这样又又可以去写一些circle了啊,什么ser什么start啊对吧。就行了啊,然后大家明白这个意思,那我们现在比如说我要执行这一段啊,还是什么呢,从卡夫卡读对吧,那把这个卡夫卡地址改一改啊,这应该是9092啊。
04:11
这个是哈豆二啊哈杜三,然后呢,Group ID给艾特硅谷CSV格式啊。呃,TABLE2,同样的,我用一个print连接器啊。然后呢?就是做一个打印呗,是吧,好,那这是这么几个思口,那接下来这边我们怎么写呢,特别简单啊table。Contest点。然后呢,写一个什么标签名称啊,First。这就完事了,你看一共几样代码,三好。说特别省事,特别美观,特别优雅呀,对吧,这就是它优雅的方式,否则呀,我们之前这三句circle都要写在哪里啊,都要写在这啊,每一个要excu circle一下啊,然后呢,还要各种号去拼接字符串啊,看起来很不方便,不灵活,那现在我要改,我直接在这很方便的去修改,要添加就加,呃不同任不同,我就呃写不同标签啊,这就完事了呗。
05:16
这就是他的优雅之处啊,三行搞定。好,那我们来执行一下,我运行啊,肯定会报错。我们看看报什么错啊?到什么?三好容易空,因为它识别不到这个配置文件,对吧,那我们怎么办呢?啊一样的啊。我先。Copy pass一下啊run edit配置我们说二要指定一个。项目的配置文件呢,一个是什么杠杠空啊,就是这个application啊,还有呢,我们要指定circle文件,杠杠circle啊,空格还是加上它的路径啊,那我把这文件名改一下就行了呗,在同一个文件夹嘛,啊circle点样嘛。
06:07
那这样就可以了啊,应用OK啊再执行。那么接下来呢,我们来试一下呗。呃,S从卡普卡里面写入,比如说S88,诶,我看一下circle里面是哪个topic啊。啊,是一这个topic。呃,八回车。看一下你看这里是不是就控制台是不是就有了,因为我们是在print这个连接器打印嘛,啊,就能够直接看到。然后再来玩一条吧,S7777,哎。是不是又有了,那就是用stream差API来写一个任务。
07:00
是不是很方便对吧。这个我们要怎么去呢?是不是同样的我们去。这里再一下把代码提交,提交完之后我们是不是一样的操作去工程理赔。如果是不同的工程,你是不是在添加工程,然后再启动应用对吧?啊就OK了嘛。那同时我们顺便提一组,有一个notebook,也就是说开发环境啊,你在这边写代码,然后直接点这个,立马就跑起来了。就是有点像基本那个功能。那可以支持很多种啊,写flink,写写PI flink。这就看你怎么去写了,你可以直接运行对吧。这是一个实验性的项目啊,这是一个官方案例啊,官方案例就这么去跑起来就可以了啊。
08:05
好。
我来说两句