00:00
好,那接下来呢,到我们的核心逻辑这一块了啊,形成广播流这块呢,我们已经做完了,对吧?啊做完了这个事情做完了,做完了之后呢,我们要连接两个流了,哎,来到这边来啊,我们要连接广播流和我们的主流,主流呢是我们的杰森。OJ。然后呢,点connect连接我们的主这个广播流叫。啊,好,那我们就得到了一个connected stream,啊,注意这个connected呢,它是一个broadcast connected stream。对吧,好,那接下来呢,我们要处理这个数据第六步,诶,大家扣666的那个时候来了,对吧?好,那我们看啊,这个位置我们得调用一个process。直接用process了,对吧,因为这里边要用到测输出流嘛,一个H流,一个卡夫卡流,所以呢,要用到测输出流,我们就只能用process,而且他也没有其他的东西来做,对吧?啊只有这个。
01:05
Process,这个process,所以呢,我们要用一个process啊,这边又一个我们应该看啊呃,那我们并不需要做key,所以new的东西呢,来看我们直接扭它就行。叫什么呢?叫broadcast process方式对吧?呃,这里面还有一个是kid,那这个是什么东西呢?是当我们主流啊,主流你做了key外,你是一个监控流的时候,跟连接一个广播流,那么你要传key的broadcast process function对吧?它根据这个key来区分的,好,那如果不是我们是普通的,那就用一个broadcast process方式就好了。啊,就做这事行,那我们就有一个叫broadca process function杰森啊,那书中呢,这个我们先不用管,先都就让它object,那这里边我们想一下啊,我们要去对这个分析了,第一个要一个process element,还有一个是process broadcast element。
02:07
啊,一个是处理主流对吧,Process element,这个是主流啊,这是主流,你看这边的上下文环境是read only,因为它是负责读状态,那这边是。广播流,广播流呢是负责写状态的,大家想一下是不是。没问题吧,所以这个呢,用来处理广播数据这个。用来处理。主流数据。啊,用来处理主流数据,OK,那我们要分析一下这两个流里边我们分别要做哪些事情,大家现在能不能告诉我一个一个讨论,对于广播流数据我们应该要做什么事?
03:08
啊,对于这个广播流,我们需要做什么事?就是这边我们要做哪些事情啊,能不能想一想,思考一下这个问题。好,那有的人说了对吧,这个是广播流。处理方案对吧,然后还有一个主流处理方案。啊,主流的处理方案对吧?好,那有同学说广播流呢,要进表那就检查。表是否存在并见表。对吧,诶这个好,那个蒋总说了要写入状态,对了啊,这个很关键对吧,这个很关键,因为只有写入状态之后,我们主流才能用吧,你不写到状态里边,我们主流怎么能从状态里获取出来呢。
04:14
好,在这个之前其实还有一件事情就干什么呢?解析数据。啊,因为我们读到的是不是一个字符传呢?我们要把这个字符转变成什么类型,还记得我们状态的KV吗?K是three value是table process,所以在这个之前,我们应该先得到这个。对,转化为招聘没有问题吧,所以在广播流里边呢,我们做的这三件事情,第一。第二。第三好,那主流呢,大家想一下,主流我们应该要做什么事?主流,我们要做什么事啊?来,有没有同学说一说?
05:02
嗯。主流里边有哪些事情需要去做一做呢?根据广播状态操作。啊,根据状态分流,OK,大体上没问题,那将根据状态分流,那么就是说读取。状态对不对,好,那接下来呢,分流。啊,大家还忘了一件事情啊,忘了一件事情,我提示你这个是第三件事情分流,第二件事情还要做什么事,在分流之前我还需要干什么事。还记得吗?有没有同学记得?
06:08
解析。过滤对了。是过滤数据吧,过滤我们不是说了s columns有两个作用吗?第一要见表对吧?啊呃,给这个数据见表,另外。我们要干什么?过滤数据啊,要过滤数据,对了,要过滤数据啊,因为我们今天举的例子被mark。对吧,被那个最后一个字段呢,可能我们不要。啊,我们是不要的,对吧?啊好,那这是广播流跟主流所做的事情,那其实这边呢,也给大家准备了,在这儿啊,那这个PPT我就不放了,因为我有分屏,PPT1放呢,这个也看不见啊好,那在这个当中呢,第一个对于广播流肯定要先处理对吧?获取并解析数据,解析成table price table process,好第二步校验表是否存在,如果不存在呢,去见表。
07:06
啊,第三个写入状态广播出去,当然广播出去这个事情不让我们做,我们只需要负责把它写到状态里边就好了,啊,只需要负责写到状态里边,好,那下来对于主流获取广播的配置信息,注意我这边有个箭头把它关联起来了,对吧,你负责写,你负责读,读完以后呢,根据里边的字段做一个过滤,第三件事情没写在这,这是最核心的分流嘛。对吧,第三件事情分流这个业务,那肯定要做的。要做这是最核心的一件事情了,要做分流对吧?好,那这是我们所看到的它的一个流程的分析,对吧?我们要知道一下,就是写代码之前一定要把逻辑梳理好,才能动手去写代码,要不然你自己脑子里边都跟浆糊一样,你写的代码肯定有问题。对吧,是这个意思啊,行,那这是我们所看到的这两个流分别要处理的,那这块有没有问题。
08:06
就是说在当前这个方法里边,我们要做123,这个方法里边也要做123,有没有问题?能不能理解应该没问题吧,啊,我相信大家应该没问题啊,虽然它很难,但是呢,呃,我们一点一点的剖析,一点一点的跟上,对吧,每一步呢,跟上他就。没什么问题了啊,他就没没什么问题了啊,No problem对吧,好。
我来说两句