00:00
好,那接下来呢,我们准备idea的这个开发环境啊,那这个呢,我们就创建一个新的。项目就行了啊,嗯,还是没问没问的啊,然后呢,也不选择任何的一个模板,直接下一步啊,然后。然后这个东西呢,我们名字已经在这已经有了,对吧?好getate地址这个啊直接拿过来,到时候呢,我们就用这个作为我们的K的地址啊,就要这个名字J个杠21126,咱们班的一个班级号可以吧,好然后呢,下一步。下一好之后呢,咱们把这个改一下啊,就放在work space这个空间里下啊完成。好呃,让他自动导入,那这个呢,是我们的一个。负模块对吧,啊,咱们呢,要做成一个。咱们做成一个子负模块,因为未来呢,我们里边有实时计算,有这个数据接口等等,有这样的一些东西,对吧?好,那在这个基础上呢,所以我们这里边儿不写代码,直接将src给它干掉啊。
01:10
直接删掉,然后在这里边呢,我们创建把它删掉,其实不删也无所谓,对吧,把它删掉呢,是防止大家未来写代码写错位置了,因为一看一个src,然后点开卡在里面写对吧,最后运行不了啊,你不要出现这样的事情,就直接就不用它啊,然后呢,在这个里边去创建一个module。啊,咱们第一块写的肯定是实时计算的啊,叫JA-real time。对吧,实时计算的啊,然后呢,下一步。好,那在这个目录底下检查一下目录啊,没有问题对吧?然后呢,直接finish啊啊接下来呢,我们就给它添加依赖啊,那这个依赖呢,我们就把它粘过来,然后呢,我们统一大家看一下,介绍一下每个依赖它有什么作用,OK吧,好,那我们到这,这是刚才我们说的创建环境啊,这没什么好说的,对吧?嗯,删除src,并创建JA real time啊。
02:07
然后呢,依赖我整个的把这个拿过来啊,看上去很多,但是呢,其实还好啊,都是我们所熟悉的一些依赖啊。来,我们来看。首先,第一部分声明了几个变量。对吧,嗯,用来限定版本的,比如说link01:13对吧,SKY的版本02:12啊哈,多版本3.1.3啊这些东西好,那么接下来依赖。弗Li Java,弗Li stream Java卡不卡的连接器,对吧?呃,弗Li客户端没有这个东西,那本地运行不了对吧?得有一个包啊,然后弗林杰森,然后呢,Fast杰森,因为我们可能会处理这种杰森格式的数据,比如说我们的行为数据也好,业务数据也好,那都是杰森格式的,对吧?所以我们导入这个呃,杰森的处理工具包啊呃,哈多客户端,因为如果我们将这个设置检查点放在HDFS,那么就要引入哈多客户端的一个依赖,要不然呢,就会执行不成功,对吧,用book。
03:14
啊,这是小辣椒,这是一个插件啊,当然你要前提装这个插件学习到现在为止,呃,这个肯定没没有问题的。对吧,然后这三个logo附件打印日志相关的依赖,最后呢,是一个打包插件啊,这块build plug打包插件,所以看着粘过来东西比较多,但实际上都是我们所用过的比较熟悉的一些依赖,对吧?好,那这个呢就搞定,把这个搞定,接下来我们继续往里边去创建我们对应的包。啊,创建我们的包,我们主要呢,创建这几个包,一个APP。启动类所存在的包对吧,然后呢,并包发病的common。产量类产量啊,UU工具包对吧,好,那我们把这个呢,先创建一下啊在这边。
04:05
嗯,包呢,我们就不直接创建那个什么APP了啊,多一点东西APP包。呃,并包。Common常量包,然后呢,一个工具包。U工具包OK吧,好,那接下来APP里边呢,咱们是要分层的,对吧,所以在这里边呢,我再继续创建一个包啊呃,首先呢,我们写的是DM层,最后啊,写的是DM层,然后呢。呃,第地层。DWS,对吧?呃,在里边呢,我们可能还会涉及到写一些函数,所以呢,我们再来一个方程。啊,再来一个方式报,比如说我们写的map函数,假如说这个函数非常复杂,对吧?啊,它不是说写这么几行啊,它有很多的方法要重写,那我们就可能写出来,可能写出来或者自定义一些比较复杂函数的时候,对吧,我们就可以写出来啊,因为这样的话,你的代码看上去不那么长,那么冗长,对吧?好,这是我们的包,先构建好,当然这个包你不构建也没问题,不提前构建,最后我们写代码的时候你再去构建,当然是没有问题的,OK吧,好,那接下来呢,在。
05:28
Resource目录底下添加我们要的东西附近。添加一个logo服务器对吧,然后呢,把打印日志的这个东西呢拿进来。好,这边呢,默认我们给的是AR对吧,这是我们今天说的,如果说你的任务没有出来结果。啊,同时他没有报错信息,那你将这个位置改成in座,再启动一下去查看有没有警告,对吧?这是一种方式啊,另外一种方式就打印法,看数据到底是从哪一块开始没的对吧?用打印法两种方式,早上说的对吧?好,这是我们老佛界,那就构建完了啊,基本的东西就结束了,对吧?好,那继续往下啊,我们把这个菲利斯一代拿进来。
06:20
啊,当然你最后拿也可以啊,嗯,因为我们很明显第一个写的就是DM槽,它要将数据呢写到。Penix的对吧,所以我们把这个Phoenix依赖导进来,我们就往后放就行了,在新添加的依赖我都往后放可以吧,除非是跟前面有相关的,比如说我再要导入,我要写flink circle,我要导入那个什么。Blink的依赖,那我就要把blink,我可能就放在flink一起,对吧,这样的话同一种依赖放在一起吧,我可能把blink放在这儿,对吧?啊,用到其他的连接器,诶,那我就放在这,比如说弗Li CDC,它有连接器对吧,那我们就可能放在弗Li格这个依赖一块啊,是这个意思对吧?啊,如果不相关的依赖呢,我们都往后追加追加啊好,这是这个依赖搞定,呃,后面呢,再遇到什么其他的依赖我们再说啊好,那接下来呢,这个东西也要导一下。
07:14
因为我们未来要在ideal里边将数据写到Phoenix,我们之前说了,Phoenix里边呢,你要去操作非default库,一定要加上这个参数,对吧?那ideal里边你去操作,同样的道理也要加上它,那我再来一个叫h base刚set。点查表文件。然后呢,把我们这个地方拿过来啊,当然考虑到大家的这个名字,或者说这个路径跟我这边呢,有可能不一样,你最好怎么办。大家我告诉你啊,你最好从这粘。喂。
08:00
对吧,你最好从你这个位置去粘,能听懂吗?你不要粘文档当中的。啊,你不要粘文档当中的,你就把这个东西给他干什么。粘过去啊,你把它你把你自己的这个东西粘过去就不会出问题,对吧,我呢直接粘文档没有问题,因为我这个文档当中东西就是我从虚拟机上粘出来的,朋友们,我就直接用这个了。好吧,我直接用这个,你们注意最好呢,你从你的虚拟机里边去粘,防止咱们有东西不一样,OK吧,但是这两个配置一样的,就怕什么呢,主机名还有这个路径这些东西不一样啊,其他的什么distribute处,还有最后这个参数,那必然是一样的,没什么好说的,对吧,最重要的就是标红的这一部分,有可能大家的主机名不叫哈,102103104,对吧,凡止这种型号出现呢,你从你的。机器当中去粘就好了,同学们这种在讲的过程当中注意事项我都给大家。
09:03
粘出来了OK吧,哎,这边好像少了一点东西是吧。我们把这个投信息也要拿过来啊,中间这个注释你想拿也可以,你不想拿也没没关系啊。但是这个查没文件的头信息你要拿过来对吧?啊,然后呢,就是这个具体的配置信息,那就没有问题了,可以吧,好这个当然这是注释啊,你要是觉得这个不爽,你就干掉对吧,这个是完全可以干掉,因为是注释,好那这一步就搞定了,我们再继续往下翻看看没有。呃,这些东西呢,都没有ready了,到最后我们需要用到的时候再去添加一辆也来得及,对吧?啊,用到的时候再去添加就都来得及啊好,那这块呢,我们的环境就已经构建好了。
我来说两句