​Kudu的读写原理

一、​​​​​​​工作模式

Kudu的工作模式如下图，有些在上面的内容中已经介绍了，这里简单标注一下：

• 每个kudu table按照hash或range分区为多个tablet；
• 每个tablet中包含一个MemRowSet以及多个DiskRowSet；
• 每个DiskRowSet包含BaseData以及DeltaStores；
• DeltaStores由多个DeltaFile和一个DeltaMemStore组成；
• insert请求的新增数据以及对MemRowSet中数据的update操作（新增的数据还没有来得及触发compaction操作再次进行更新操作的新数据） 会先进入到MemRowSet；
• 当触发flush条件时将新增数据真正的持久化到磁盘的DiskRowSet内；
• 对老数据的update和delete操作是提交到内存中的DeltaMemStore；
• 当触发flush条件时会将更新和删除操作持久化到磁盘DIskRowSet中的DeltaFile内，此时老数据还在BaseData内（逻辑删除），新数据已在DeltaFile内；
• 当触发compaction条件时，将DeltaFile和BaseData进行合并，DiskRowSet进行合并，此时老数据才真正的从磁盘内消失掉（物理删除），只留下更新后的数据记录；

二、kudu的读流程

• 客户端向Kudu Master请求tablet所在位置
• Kudu Master返回tablet所在位置
• 为了优化读取和写入，客户端将元数据进行缓存
• 根据主键范围过滤目标tablet，请求Tablet Follower
• 根据主键过滤scan范围，定位DataRowSets
• 加载BaseData，并与DeltaStores合并，得到老数据的最新结果
• 拼接第6步骤得到的老数据与MemRowSet数据 得到所需数据
• 将数据返回给客户端

三、​​​​​​​​​​​​​​kudu的写流程

• 客户端向Kudu Master请求tablet所在位置；
• Kudu Master返回tablet所在位置；
• 为了优化读取和写入，客户端将元数据进行缓存；
• 根据分区策略，路由到对应Tablet，请求Tablet Leader；
• 根据RowSet记录的主键范围过滤掉不包含新增数据主键的RowSet；
• 根据RowSet 布隆过滤器再进行一次过滤，过滤掉不包含新数据主键的RowSet；
• 查询RowSet中的B树索引判断是否命中新数据主键，若命中则报错主键冲突，否则新数据写入MemRowSet；
• 返回响应给客户端；

四、kudu的更新流程

更新删除流程与写入流程类似，区别就是最后判断是否存在主键时候的操作，若存在才能更新，不存在才能插入新数据。

• 客户端向Kudu Master请求tablet所在位置
• Kudu Master返回tablet所在位置
• 为了优化读取和写入，客户端将元数据进行缓存
• 根据分区策略，路由到对应Tablet，请求Tablet Leader
• 根据RowSet记录的主键范围过滤掉不包含修改的数据主键的RowSet
• 根据RowSet 布隆过滤器再进行一次过滤，过滤掉不包含修改的数据主键的RowSet
• 查询RowSet中的B树索引判断是否命中修改的数据主键，若命中则修改至DeltaStores，否则报错数据不存在
• 返回响应给客户端

​