庖丁解LevelDB之Iterator

通过之前对LevelDB的整体流程,数据存储以及元信息管理的介绍,我们已经基本完整的了解了LevelDB。接下来两篇要介绍的内容并不是LevelDB的基本组成,却是让LevelDB更优雅高效的重点和体现,Iterator就是这样一种存在。

作用

正如庖丁解LevelDB之数据存储中介绍的,LevelDB各个组件用不同的格式进行数据存取。在LevelDB内部外部,各个不同阶段又不可避免的需要从不同的视角遍历这些数据。如果每一个层次的数据遍历都需要详细的关心全部数据存储格式,无疑将使得整个过程变得无比的冗余复杂。Iterator的出现正式为了解决这个问题,Iterator在各个层次上,向上层实现提供了:

无须了解下层存储细节的情况下,通过统一接口对下层数据进行遍历的能力。

接口

Iterator用确定的遍历接口将上层需求和下层实现解耦和。熟悉STL的同学一定不会陌生Iterator的使用方式,这里LevelDB的Iterator接口包括:

  • Seek到某一位置:Seek,SeekToFirst,SeekToLast;
  • 访问前驱后继:Next,Prev;
  • 判断当前位置是否有效:Valid;
  • 获取当前位置数据信息:key,value,status;
  • 可以注册多个Cleanup方法,当Iterator析构前做一些清理操作。

分类

LevelDB大量使用了各种Iterator,根据Iterator的实现和层次,我们将其分为三种类型:

  • 基本Iterator:最原子的Iterator,针对相应的数据结构实现Iterator接口;
  • 组合Iterator:通过各种方式将多个基本Iterator组合起来,向上层提供一致的Iterator接口。
  • 功能Iterator:某种或多种组合Iterator的联合使用,附加一些必要的信息,实现某个过程中的遍历操作。

基本Iterator

LevelDB中包括三种基本Iterator,他们分别针对Memtable,Block以及Version中的文件索引格式,实现了最原子的Iterator:

1,MemTableIterator

在Memtable Skiplist的格式上的Iterator实现。Memtable格式见庖丁解LevelDB之数据存储

2,Block::Iter

针对SST文件Block存储格式的Iterator实现。遍历的过程中解析重启点,拼接key的共享部分和特有部分,获取对应的value值。Block详细格式见庖丁解LevelDB之数据存储

3,Version::LevelFileNumIterator

庖丁解LevelDB之版本控制中介绍了Version中记录了当前所有文件按层次划分的二维数组。其中Level1层之上的文件由于相互之间没有交集且有序,可以利用文件信息中的最大最小Key来进行二分查找。LevelFileNumIterator就是利用这个特点实现的对文件元信息进行遍历的Iterator。其中每个项记录了当前文件最大key到文件元信息的映射关系。这里的文件元信息包含文件号及文件长度。

组合Iterator

组合Iterator由上述多个基本Iterator或组合Iterator组合而成,LevelDB中包含两种组合Iterator

1,TwoLevelIterator

TwoLevelIterator实现逻辑上有层次关系的数据的遍历操作。组合了index iteratordata iterator两层迭代器,其中index iterator记录从数据key值到data iterator的映射,而data iterator则负责真正数据key到value的映射。生成TwoLevelIterator时,需要提供index Iterator及BlockFunction函数,其中BlockFunction实现了index iterator value值的反序列化以及对应的data iterator的生成。

2,MergingIterator

通过MergingIterator可以实现多个有序数据集合的归并操作。其中包含多个child iterator组成的集合。对MergingIterator的遍历会有序的遍历其child iterator中的每个元素。

功能Iterator

为了实现不同场景下不同层次的数据遍历操作,可以联合一种或多种组合Iterator,这里称为功能Iterator,按其所负责的数据层次由下自上进行介绍:

1,Table::Iterator

对SST文件的遍历,通过庖丁解LevelDB之数据存储可知,这里有明显的层级关系,可以利用上面介绍的TwoLevelIterator,其index iterator为Index Block的Block::Iter,data iterator为Data Block的Block::Iter

Table::Iterator

2,Compaction过程Iterator

Compaction过程中需要对多个文件进行归并操作,并将结果输出到新的下层文件。LevelDB用MergingIterator来实现这个过程,其clild iterator包括庖丁解LevelDB之版本控制中提到的要Compaction的多个文件对应的Iterator:

  • 如果有Level0文件,则包含所有level0文件的Table::Iterator

  • 其他Level文件,包含文件索引的TwoLevelIterator,由Version::LevelFileNumIterato作为index iterator,Table::Iterator作为data iterator

Compaction过程Iterator

3,NewInternalIterator

LevelDB作为整体同样通过Iterator向外部用户提供遍历全部数据的能力。这里使用MergingIterator将Memtable,Immutable memtable及各层SST文件的Iterator归并起来,使得外部使用者不用关心具体的内部实现而有序的循环LevelDB内部的数据,LevelDB首先实现了NewInternalIterator:

Imgur

在NewInternalIterator的基础上,LevelDB有封装了DBIter来处理快照,过滤已删除key。

参考

Source Code:https://github.com/google/leveldb

庖丁解LevelDB之概览: http://catkang.github.io/2017/01/07/leveldb-summary.html

庖丁解LevelDB之数据管理: http://catkang.github.io/2017/01/07/leveldb-summary.html

庖丁解LevelDB之版本控制:http://catkang.github.io/2017/02/03/leveldb-version.html

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 版本控制或元信息管理,是LevelDB中比较重要的内容。本文首先介绍其在整个LevelDB中不可替代的作用;之后从...
    CatKang阅读 5,539评论 12 12
  • 作为一个存储引擎,数据存储自然是LevelDB重中之重的需求。我们已经在庖丁解LevelDB之概览中介绍了Leve...
    CatKang阅读 4,709评论 2 11
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,001评论 19 139
  • LevelDB是Google传奇工程师Jeff Dean和Sanjay Ghemawat开源的KV存储引擎,无论从...
    CatKang阅读 4,868评论 5 25
  • 宝贝马上过一周岁生日了,加紧画几张!宝爸说我总是他给我和宝宝拍照,我都不关注宝宝和他,今天画一张他和宝贝的合照!看...
    土左旗025李飞飞阅读 180评论 0 1