00:00
呃,那在这里边呢,还有第三步要做一个分流处理啊,要做一个分流,那如果是卡夫卡,那就放到主流对吧?好,呃,但是在这个分流之前,我们还要做一个事情来,我们先把分流代码写好啊,If这个地方table process点卡不卡点equals谁呀,从这个table process当中get think table对吧?那这个是卡不卡数据啊,那这个呢,我们写一下卡不卡数据。写入主流对吧,可把数据写入主流,那主流呢,我们正常的用这个上面的out去写,对吧,点connect,把这个value呢写出去好else。我们加个if,最好加if判断对吧,Table当中think,我们table process里边获取think table啊好那家两个think table都获取了,我们就在这。
01:04
把统一获取一下,得到一个think table think table对吧,好,那这个放在这啊,这边一样的把这个替换掉,那这个呢,是数据写入测数主流。写入。侧输出六对吧,那就是ctx来写的点。奥的奥的他我们已经有了,对吧。下面我们叫object,我看一下。我们取的名字啊,对,叫object,呃,Out,行,那就叫这个名字,接下来呢,回到这来。Value,那肯定还是我们的value本身不变。好,那这个时候我们在这个之前还要做一个什么事呢?是这样啊,那我们想现在呢,只是分成了两个流吧,只是分成两个流,也就是说接下来呢,我们分成了卡夫卡流和H流,接下来往分别往卡巴写和H写,我们还要对这个数据做加工做处理,对吧?呃,那接下来我们想啊,写到卡夫卡主流的数据是不是应该有很多实时表,假如说我举个例子,20个可以吧。
02:17
有20个事实表,好,那写到维度当中也有20个吧,啊还有六个表我们不要,因为我们说有的表不要嘛,对吧,写出去有20个维度表要写出去。那这个里边也就相当于主流当中有20个主题的数据,然后这个里边呢,有20个维度表的数据,也就是说他们每个人的表不一样,每个人的主题不一样,那我仅仅把这个Y6写出去,它。知道自己所要写的表或者说主题吗?我Y6中有这个数据吗?
03:04
Y6是什么格式啊在这。对不对,我Y6里边儿有数据吗。有他往哪写的数据吗?对,根本就没有对吧,所以要注意一下,在分流数据之前,我们应该做一个什么事啊,在这边交。输出表。或者是什么主题信息写入value啊才可以,那就value.put啊叫think table。好,Table process当中get table,诶把这个数据写进去。
04:00
啊,那只有把这个数据写到Y6里边,再随着Y6往下游传,下游我对这个数据进行加工,或者说对这个数据进行加工的时候,是不是才有可能将不同的事实表写到不同的主题,将不同的维度表写到不同的pix表啊。能不能理解这个事儿?能想明白吗?应该没有问题吧,啊这个呢,其实比较简单啊,就是说你一定要把它写出去,你不写出去下游没办法处理了。对吧,下游你接下来这里边20个,这里边20个,你接下来这个数据往哪写了,这不根据这个吗?对吧,这里边可能有20度这样的东西啊行,那这块呢,我们分流这个也就搞定了,对吧?啊那到这块为止,我们整个动态分流的代码。
05:02
写了2/3了啊,因为就只差最后把这个要分到不同的主题,把这个分到不同的维度表嘛,对吧?啊,完成了2/3了,我只能说完成2/3了啊。
我来说两句