00:00
哎,现在这个来我们就这块呢,单的处理我们做完了,那接下来呢,我们把它进入到这个方法对吧,这个方法呢,是处理这个多个event啊,放到一个集合里面,那这又怎么做呢。哎,通常呢,我们是拿到这个例子,那你想这里面我们的原则就是我会调用这个方法,调用这个方法它有两个返回值,一个呢是一个是啊。这个值返回的是空,说明什么呢?说明它是一个张数据,我们想做的就是在这个集合里面把这个数据给我踢出去。你没了。那不就OK了?对吧,这原理就是,哎,我这个这里面有大量的数据,大数据,你过来一个,我判断判断你这个返回值是不是空,因为这块你就是校验它是不是一个介设,哎,如果返回空咔删掉。啊,然后如果这个反向空咔删掉,那剩下的都是正常符合条件的。
01:00
啊,这么个思路,那这怎么怎么做啊,有同学说这个风循环行不行。比如说放。丸。风行玩你说行不行呢?哎,不行啊,这里面要是从一个集合当中删除出去,哎,都得用谁呢,迭代器。哎,用迭代器呢,去把它删除掉啊相的数据,比如说外循环。第二,Has是否有下一个,如果有下一个的话呢,你需要出来下一个,那就是。点吧。OK,把这个N取出来,那取出来之后把这个nice传给谁呢他。用它来用对吧,取出这里面一个一个的值。去,那你传进去的话,它会有返回值,它的返回值就有两个啊,一个呢是空,一个呢是。对吧,嗯,那如果。
02:09
对吧,哎,如果你返回值等于空啊,你看一下啊好。它等于空,那我就从这个迭代器里面把它没掉就完事了啊,然后剩剩下的这个list里面存储的数据,那就是正常的啊,滤掉张数据的及格了。来吧。在这里面,那就是如果说它等于空,我就从这个集合里面。啊,这个哈。第二啊,把它删除掉之后,最终返回这个。真的这个集合啊,从这个集合里面啊,把取出来数啊滤掉就OK了啊这呢是这是这块啊,这个多基本的集合给处理完了,处理完之后呢,我们还差一个,差一个静态内部类。
03:03
这个。然后。那这个build实现一个接口实现,实现这个cept实现。哎,然后重写里面两个方法告诉加回车。OK。同时在这个标里面需要创建一个自己,这个对象有一个ETL进到上面,哎,创建的是自己。把它自己创建一个实例,放在这后面的话,就可以调用它了。好,这样呢,拦截器我们就编写完了,那接下来呢,我们需要对它进行一个打包编译,首先呢,来到右上角这块呢,有一个ma,诶点击它。让他点击这里面的pack,双击。这样呢,就对这个代码啊,进行一个打包编译。
04:00
编译完成之后,首先观察左侧这边有一个target,哎,那最下面这块呢,生成两个夹包,那么来看一下右键open,哎,进来进来之后这两个夹包,那这两个夹包有什么区别呢。哎,那大家回忆一下,在我们的POM文件当中,是不是有一个阿里的一个架包啊,Fast杰森是这样吗?那这个fast杰森在我们整个弗鲁姆集群当中有没有呢?是不是没有啊,哎,那如果没有的话,那这块我们要选择哪一个加包呢?是不是要选择这个带依赖的这个加包啊,因为有了它之后,那这个集群上没有发子健身包,我们也是能够运行对应的代码的。好,那下面呢,我们就将这个价包上传到对应的集群上好吧。那门打开。CD力表包向,然后呢,将这个带依赖的夹包往里面一拖。那这样呢就OK了,那下面我们来看一下有没有LS过滤一下。
05:05
OK,哎,现在呢,就找到了对应的这个,哎,这个带依赖的加包,然后呢,对它进行一个分发XSYNC。好,那错。那这样呢,就分发完毕了,分发完毕啊,这个拦截器我们是有了,那下面这个拦截器如何跟我们之前写的这个配置文件关联起来,知道吧?哎,之前我们写到这个配置文件当中,这个type类型是不还没有配置啊,还有印象吗?是吧,那这块应该怎么配呢?它应该配置啊我们这个拦截器对应的全类名。那这个全类名找一下。来到这儿,然后呢右键。这里面有一个copy,哎,Copy学列名喊过来。然后往这一放,那后面还需要加上什么内容呢?哎,还需要加上这个Dollar build。
06:00
Build build,其实这个build就是我们之前写代码当中的谁呢?哎,就是他。那就啥,比如说把它拿过来也行一样的。好吧,哎,这样一个过程,行,那这个排准键我们也写完了,那怎么办呢?哎,我们需要把它。放到我们整个集群上,放到什么集群什么位置呢。然后这个位置。CD。在这里面我们来编写一下这个配置文件啊,VM,那这个文件名称啊,我们通常是这样起的啊,File,然后中杠。然后之后呢,是卡不卡。点好,那这文件为什么这样去命名呢。你看我们读取的内容是不是一个file啊,哎,是文件,然后中间我们是你看file对塔对塔,然后我们输出的目标地址是不是卡普卡呀,哎,所以说目标地址是卡普卡,哎这样呢去起名字哈,好。然后放过来。三哎,那整个类配置文件我们就写好了。
07:01
切好之后啊,接下来呢,我们把这个呢也分发一下XSYNC。搞定。搞定之后,那下面我们来启动一下对应的我们这个flu,那启怎么启动呢?我们来看一下这个文档当中啊相关的一个说明。那在这块。这块呢,我们就可以启动对应的flu,那怎么解哎,变flu NG下边有一个agent。来调用它,然后你这个agent的名称,我们配置文件当中agent的名称是不是A1啊对吧?哎,好,那接下来它要指定配置文件杠杠five。那你这个配置文件在哪里呢?诶,那在你当前这个目录下有一个K康,下面存在一个fire,卡不卡啊是它吧?诶然后后面呢,这个是在后台进行一个运行,那这呢就是启动对应的这个flu啊,那下面我们来执行一下吧。
08:01
然后这里面。好,那现在呢,这个嘛,就启动起来了啊,GPS一下,那找一下对应的这个进程。Application知道吧,哎,这个呢,就是flu对应的这个后台进程,那同时呢,下面呢,我们也把这个,哎这个103上的也启动一下。三天啊。OK,启动起来了,看现在呢,这个application也已经OK了。
我来说两句