15-尚硅谷-Flume进阶-事务

好，那我们看下进阶这块啊，今天这块呢，后面的这些的案例啊，是生产环件当中，我们可能会用的比较多一些啊，不是单个节点了，就是后面我们之前不说过他是集群开发嘛，是不是提到过这个事对吧？啊后面呢，就是说多台节点共同工作啊，现在呢，我们都单个节点就相当于入门案例嘛，我们写的叫入门案例对吧？啊那接来我们看下进阶这边啊，第一个是from当中的事物啊，那我们看一下，其实嗯，South跟China，还有这个China跟信，通信的时候都是有事物啊，如果发过程当中出现问题了，它会干什么回滚啊好，首先呢，是还是我们的这个组件对吧？我们常规的组件，这是数据源source接收数据的啊，然后呢，在这里边封装even的，他呢需要把数据发给什么China，然后关键的问题在于think呢，对接IDFS，这个要注意一下啊，这里面数据呢是S。

在主导地位的就是think来拉取数据的啊，是think拉的啊，不是说这边south呢，是south将数据推给China的，但是不是China将数据推给这个C的，而是think来拉取的啊，所以呢，我们来看一下这个在推送过程当中呢，它会有事物啊不的事物流程对吧，是这样的东西，他会先呢，有一个他正常的也是一个批次一个批次发的。啊，当然如果说你半天只有条数据，它也照样发，对吧，我们是不是看到了，如果说我们是输入一条数据，它照样也会上传啊，对吧？啊，那这个呢，是批量，如果说你很短时间内能有批量数据才会发，他先写就是开启发送数之前开启一个事物啊，它需要开启一个事物，然后呢，这个事物的名字注意叫不的事。就是刚才我们说的，它是由SAS往这边干什么去推送的啊，它先放到这个督库的，就是它里边调动方法先写到一个临时缓冲区，然后呢，检查多抗密的会去检查参测当中是否有足够的队列。

就空间还够不够对吧，如果不够了，如果够的话，那就往里写呗，对吧，写的话就真正的去做提交，如果不够怎么办。回滚对，就要回滚了，如果不够我就写不出去了呀，就要回滚放到SS里面了，对吧，还放在套子里面，下一次再接着是不是还要发这个数据对吧？保证这个数据不丢啊，这边呢，所谓叫put数据，那你要记的东西这里面呢，有多put put list啊，记这些东西就行了，一个叫put事物对吧，都put put list啊，如果说失败，或者说什么样，内存空间不足，做回滚back回滚对吧？好，这边呢，是有一个put的数，那对于后边呢，还有一个。叫take数，刚才我们是不是说过，这边的数据通信不是说China发给你的，而是由think来干什么来拉取的，所以叫什么take对吧？啊叫take这个，然后拉取时间也一样的，它中间呢，有一个take例子。

啊，先放到缓冲区对吧，然后呢，尝试往里去写啊尝试往写，如果说写成功了，那么清清空，如果没写成功呢，所谓的叫做回滚，那就是不清，他就相当于做回滚。因为它是要结合着这个take list往里发的，如果你这个take还有东西，那我接下来是不是还得发它呀，对吧，发成功了我就给它清掉，不成功我就不清啊，这边呢，是我们所说的一个。叫take个事物啊，叫这个事物是这样的一个内容啊好，这两个事物呢，到时候我们在自定义，现在呢，你去把里边东西去记一下，对吧，到时候我们会后面是不是我们看到叫自定义source，要自定义think。对吧，我们到时候会点到源码里边，诶，我们能看到这些东西啊，到那个时候呢，大家把详细的流程去记一下就好了，现在只要记几个名词知道，首先第一个啊，在对句外知道风当中有两个地方有事物，South和China的通信有事物叫什么事物，Put事物，对吧，是推送的。另外一边China跟think这边也有一个事物叫take事物，因为它是think主动来拉取的。

啊，然后接下来稍微记些名词，有do put put list，有do take take list啊记到这就够了啊，你先记一下啊，先强细把记一下，因为后面呢，我们要在源码当中是要去点一点给大家去看到这些内容的，对吧？更深的东西，或者说它用到什么内容，要去怎么样去归滚，我们都能看得到啊后面呢，我们详细介绍，现在呢，相当于一个理论，一个铺垫，就知道一下这个事儿，能理解这个事吗？啊好，这是我们所聊的一个事物啊。