00:00
好,那刚才我们聊了,这里边呢,得有三件事情,这里面也有三件事情对吧,而且呢,每件事情其实嗯,有的事情还并不那么简单,所以如果全部写在这儿的话,比较麻烦,比较麻烦,所以呢,我们给它写出去,我写到这个方式里边。对吧,写出去叫table。Process function。Table方式好,那肯定要实现或者继承这个东西,对吧,那我们看一下这个呢,是一个抽象类,所以呢,我们继承它就好了,In in out好,这边呢,我们把它拿过来。启程。Broadcast process方程对吧?然后导一下这个包,它呢要两个参数,1112和out对吧,一二,这个是规定好的,一个是接,第一个是string,那我们想一下输出数据我们用什么类型的。
01:00
最后一个是out。那我们用什么类型呢?大家想一下,我们输出这个类型应该用什么?主流的数据输出类型应该是什么?接森object啊,可以接object的,其实接object或者three是不是都行啊,对吧?啊,但是接object呢更好一点,因为方便后续再进行加工,因为当前我们这个时候啊,只分成两个流,一个H流,一个卡普卡流,但是h base里边有很多维度数据,卡普卡里边有很多这个。事实数据,所以我们还要对这个数据再进行加工处理,对吧,所以用接最好的奥回车啊,实现这个方法,那我们一般的先处理它,所以呢,我们把它拿上去啊。
02:06
把它拿到上面来好,呃,那接下来呢,我们这个里边,我把逻辑写一下,这里边呢,做的三件事情,第一件事情广播流里边第一件事情是什么。获取并解析数据对吧?好,第二件事情见表,我就直接简单一点叫建表,第三件事情写入状态广播出去对吧?好,那这个呢,我们也要做这三件事情啊,第一。获取状态数据。第二。过滤缩段第三件事情,那就是分流对吧?啊,那我们要做的事情就是这样子的,比较简单一点啊,把它写上来好,那这里面由于要建表,由于要见表间表呢,是菲ix的对吧?所以呢,我们在这里边应该有一个open方法。
03:06
然后呢,我们把这个。连接是不是写到这个里边了,对吧,在这初始化啊,不需要每一条数据来了都初始化啊呃,那这边呢,我们就private一个connection。好,然后呢,在这里边去初始化我们的一个连接,对吧,那就是drive啊,先是class啊,class.for name啊,然后呢,这边搞一个驱动,然后呢是connection。副值对吧,然后呢是driver manager。点get collection要一个这个URL,要一个URL就行了,然后呢,我们在这里边去用建表语句肯定会用到对吧?呃,那这个地方呢,有一个驱动,有一个这个ul我就不写了,直接呢搞一个常量类好吧。程序分析啊,这个做过了,然后接下来呢,我们搞一个常量类,然后这个里边就放了我们的。
04:00
Driver和ul地址对吧?好,那JA拿过来。在我们的common里边再来一个类。啊,不是来一个j more con类对吧,然后接下来呢,把这个三个常量拿过来。把这三个常量拿过来好,那回到我们刚才table这个方程,那这个呢,就有东西可以写了。叫寂寞。Conflict点我们的driver,它的驱动对吧,然后呢是URL叫G末conflict.phoenix so。那这个就搞定了对吧,这个搞定了好,那这来还有一堆事情我们去处理一下啊,什么事呢,就是他边边角的一些工作啊嗯,那第一个我们想啊,这个地方呢,我们要做分流,分流的话肯定测输出流嘛,所以我们肯定要有测输出流标记,关键的问题在于我们未来分好流之后,这个地方就不是它了,对吧,不是它了啊把这个干掉,你看又有一个叫table process function。
05:12
对吧,那未来这个主流我们拿到之后,它肯定是一个卡夫卡的一个流。对吧,是一个卡夫卡的数据流啊,那另外呢,从卡夫卡当中我们要获取测数据流是我们的,所以在外面获取的时候,我们是这样。点get set output,要一个output t,那么这个里边是不是同样的也要一个outp t,那这个呢,我写一次是不是就够了,所以呢,我可以通过构造方法给它传进来啊,那这个out t呢,我们写在外面又有一个out for t啊,我们把准备工作先做好啊,那这个呢,数据我们也用J3啊,不对,两个流的数据一样,这个呢是。他。
06:00
得到一个h base塔,好把主逻辑先搭起来对吧?好,这样的话我们就得到了一个h base。好卡不卡,主流测输出流,那这个东西呢,我们是不是可以给它传进去。对吧,哎,作为参数传进去,那这样的话,里边跟外面肯定就一样了啊,这第一个我们要传的参数,第二个在这个当中我们要去获取状态,往状态写的时候大家看啊,这个地方ctx点。然后呢,我们要获取状态。看他是不是也要一个map c的描述器。对吧,它也要一个这样的东西,那同理,我能不能把外面定义好的这个map c的描述器给他干什么传进来,对吧?所以呢,我们把相应的参数先准备好。啊,就是说一个是标记一个这个东西,当然有的人说我就不传递了,我就在里面自己写行不行可以,那你要保证外面跟里面写的一样。
07:04
就OK了,对吧,那我用外面的传进去,这样更好一点,那我绝对是一样的啊,绝对是一样的,所以呢,我在这边再加两个属性,加两个属性写一个构造方法,对吧?第一个属性呢,就是private啊,叫我们的output。呃,另外一个属性是map。对吧,然后这里边类型我们也可以写一下string。Table process啊,当然你也可以不写类型对吧?啊,那这边呢有一个map state,那接下来呢,我们写一个构造方法啊,奥加音色的的选我们的和卖。对的啊,把它选上就行了,好。
08:02
就搞定了,当然这块呢,我们先注意掉,让他不报错对吧,那这个不报错了,这边呢也不报错了,也不报错了,我刚才做的事情我知道之前像到这块为止,大家都都能理解,现在我加了这两个属性,并加这个构造方法能不能理解?这一块因为涉及到代码来回切啊,我去解释来回切,我不知道大家那边会不会形成花瓶啊,或者什么样子,大家来做一个调查,能不能理解这个事情。这相当于我们做了一个准备工作,但是他不难啊,他不难就是来回切,有的同学可能觉得,哎,这个来回切太频繁了,可能一下子听的是不是晕了,对吧?防止这种情况,所以先问一下大家,我觉得应该问题不大吧,应该问题不大啊,就是说我们要把这个,因为里边需要用到这些参数,所以呢,里边跟外面都用,那我就做一个参数传进来,这样更好一点,对吧,没必要在里边再去定义,当然我在里边再写一套也可以,对吧,我写一个完全一样的没问题啊,但是呢,没必要是吧,好,这个。
我来说两句