00:00
好,那接下来呢,我们写代码,写代码呢,我把这个拿一下啊,把这个名字,诶这个还没关,你看跑了一中午啊。然后呢,我们到这边来。APP我再建一个这个内容,建一个这个,呃,DWM层的一个包了,对吧,建一个账类啊DWM层点。叫unde visit visit的APP啊,就叫这个名字,好吧,保存,然后接下来呢,我们先梳理我们的思路,一样的我们再梳理一遍啊,就是把这个注释先加上。第一步啊,太简单了啊,大家都知道的。第二个读取卡不卡啊,哪个主题啊,之前我们说了,我们用页面日志,所以呢,就是DWD叫K。
01:03
Log主题的数据对吧?呃,那接下来呢,正常来说。我们要将每行数据转化为监测对象。对吧,我们要把这个数据呢,转化为接对象。好,那。接下来我们是不是可以做过滤了?过滤数据对吧,那用状态编程的啊,用到这个知识点只保留。每个mid每个mid每天第一次登录的数据,对吧,我们要做到这样的一个事情,所以这里边呢,我写的是过滤,大家在过滤之前实际上还有一次K败没问题吧,还要按mid进行一次替败啊,不要忘了,所以呢,先写了每个m mid每天第一次登录啊好,那这个过滤考数据以后,我们就可以第五步了啊,将数据写入考到啊,写入课法,写回到卡法DWM层对吧?啊,那这个呢,可以当是呢,写之前我们肯定要做一个打印。
02:20
对吧,第二步启动,嗯,那这个呢,就比较简单的一个需求,很简单,一个需求好第一步我们去随便拿一个啊,咱这边就到它了。把这个拿过来。啊,把人弄来。好,第二个读取这个主题,那这样我也去拿一个东西,我这个就不写了,我把什么拿过来呢啊。每次都自己敲,对吧,不写了,呃,然后呢,一个主I source topic think topic OK吧,这个没什么问题啊呃,接下来in.at think at source,然后MY卡夫卡YouTube.get卡夫卡的一个consumer消费者啊,然后呢,这边放source topic,然后group ID啊,得到了一个卡尔的一个DS。
03:13
得到一个卡法DS,接下来呢,我们就拿这个卡法DS。做杰森的一个转换,那这个也很简单,直接调用一个map啊,因为前面我们都已经过滤过了,所以呢,这块就不用再关心什么过滤了,对吧,你直接做一个那个map,然后呢是一个LA。嗯,应该直接这样,我们要调用杰森里边的什么pass,杰森这个里边的pass object。啊,直接这样CL加V得到一个呃,杰森OBJ的一个点。好,接下来呢,我们是过滤数据,过滤数据呢,我们说过先要做这个KKB还是按照m mid啊按照那这边呢是杰森。
04:01
OBBJ,对吧?那就接上object,先去获取我们的common字段,然后再获取我们的mid对吧?获取mid,好,这样的话我们就得到了一个K的string。得到了一个K的好,那接下来呢,我们把这个。
我来说两句