00:00
好,那我们看下进阶这块啊,今天这块呢,后面的这些的案例啊,是生产环件当中,我们可能会用的比较多一些啊,不是单个节点了,就是后面我们之前不说过他是集群开发嘛,是不是提到过这个事对吧?啊后面呢,就是说多台节点共同工作啊,现在呢,我们都单个节点就相当于入门案例嘛,我们写的叫入门案例对吧?啊那接来我们看下进阶这边啊,第一个是from当中的事物啊,那我们看一下,其实嗯,South跟China,还有这个China跟信,通信的时候都是有事物啊,如果发过程当中出现问题了,它会干什么回滚啊好,首先呢,是还是我们的这个组件对吧?我们常规的组件,这是数据源source接收数据的啊,然后呢,在这里边封装even的,他呢需要把数据发给什么China,然后关键的问题在于think呢,对接IDFS,这个要注意一下啊,这里面数据呢是S。
01:00
在主导地位的就是think来拉取数据的啊,是think拉的啊,不是说这边south呢,是south将数据推给China的,但是不是China将数据推给这个C的,而是think来拉取的啊,所以呢,我们来看一下这个在推送过程当中呢,它会有事物啊不的事物流程对吧,是这样的东西,他会先呢,有一个他正常的也是一个批次一个批次发的。啊,当然如果说你半天只有条数据,它也照样发,对吧,我们是不是看到了,如果说我们是输入一条数据,它照样也会上传啊,对吧?啊,那这个呢,是批量,如果说你很短时间内能有批量数据才会发,他先写就是开启发送数之前开启一个事物啊,它需要开启一个事物,然后呢,这个事物的名字注意叫不的事。就是刚才我们说的,它是由SAS往这边干什么去推送的啊,它先放到这个督库的,就是它里边调动方法先写到一个临时缓冲区,然后呢,检查多抗密的会去检查参测当中是否有足够的队列。
02:06
就空间还够不够对吧,如果不够了,如果够的话,那就往里写呗,对吧,写的话就真正的去做提交,如果不够怎么办。回滚对,就要回滚了,如果不够我就写不出去了呀,就要回滚放到SS里面了,对吧,还放在套子里面,下一次再接着是不是还要发这个数据对吧?保证这个数据不丢啊,这边呢,所谓叫put数据,那你要记的东西这里面呢,有多put put list啊,记这些东西就行了,一个叫put事物对吧,都put put list啊,如果说失败,或者说什么样,内存空间不足,做回滚back回滚对吧?好,这边呢,是有一个put的数,那对于后边呢,还有一个。叫take数,刚才我们是不是说过,这边的数据通信不是说China发给你的,而是由think来干什么来拉取的,所以叫什么take对吧?啊叫take这个,然后拉取时间也一样的,它中间呢,有一个take例子。
03:07
啊,先放到缓冲区对吧,然后呢,尝试往里去写啊尝试往写,如果说写成功了,那么清清空,如果没写成功呢,所谓的叫做回滚,那就是不清,他就相当于做回滚。因为它是要结合着这个take list往里发的,如果你这个take还有东西,那我接下来是不是还得发它呀,对吧,发成功了我就给它清掉,不成功我就不清啊,这边呢,是我们所说的一个。叫take个事物啊,叫这个事物是这样的一个内容啊好,这两个事物呢,到时候我们在自定义,现在呢,你去把里边东西去记一下,对吧,到时候我们会后面是不是我们看到叫自定义source,要自定义think。对吧,我们到时候会点到源码里边,诶,我们能看到这些东西啊,到那个时候呢,大家把详细的流程去记一下就好了,现在只要记几个名词知道,首先第一个啊,在对句外知道风当中有两个地方有事物,South和China的通信有事物叫什么事物,Put事物,对吧,是推送的。另外一边China跟think这边也有一个事物叫take事物,因为它是think主动来拉取的。
04:18
啊,然后接下来稍微记些名词,有do put put list,有do take take list啊记到这就够了啊,你先记一下啊,先强细把记一下,因为后面呢,我们要在源码当中是要去点一点给大家去看到这些内容的,对吧?更深的东西,或者说它用到什么内容,要去怎么样去归滚,我们都能看得到啊后面呢,我们详细介绍,现在呢,相当于一个理论,一个铺垫,就知道一下这个事儿,能理解这个事吗?啊好,这是我们所聊的一个事物啊。
我来说两句