- Java锁的逻辑(结合对象头和ObjectMonitor)
- 还在用饼状图?来瞧瞧这些炫酷的百分比可视化新图形(附代码实现)⛵
- 自动注册实体类到EntityFrameworkCore上下文,并适配ABP及ABPVNext
- 基于Sklearn机器学习代码实战
在介绍倒排索引之前,先看看传统b+tree索引是如何存储数据的,每次新增数据的时候,b+tree就会往自身节点上添加上新增数据的key值,如果节点达到了分裂的条件,那么还会将一个节点分裂成两个节点.
想一个场景,如果对用户的性别建立b+tree索引,性别只有男女之分,这样存在b+tree里是不是会存很多重复的key,如果用户数据量很大,我们想筛选出性别是男性的用户,是不是要遍历大量的数据.
而这种选择性不高的数据,用倒排索引来做就很合适,倒排索引在面对那么多用户数据的情况下,只会存两个key值,分别是男女,然后key对应的value值就是用户id的集合,能一下就找到特定性别的用户.
那么倒排索引究竟长什么样呢?
还是拿刚才那个场景举例,用于查询的key,构成倒排索引的词典,而每个词(key)都对应一个倒排列表,例如男性的key 对应的倒排列表 就包含了所有性别为男性的uid,而女性的key对应的则是另一个倒排列表,这个列表的uid全为女性.
那么这样的索引结构,我们究竟应该如何来实现呢。为了简单起见,先来构建一个在内存上能用的倒排索引.
当我们在搜索特定key对应的uid集合时,目的是找到容纳uid集合的倒排列表,要找到倒排列表就必须找到与之对应的在词典中的key值,所以我们先来看看如果你来实现一个词典的结构,你会怎么做.
词典不外乎就是在一堆key值中找到某个特定的key值,我们可以直接采用hash结构嘛。直接将词典中的每个key设置为hashmap的key,倒排列表设置为hashmap的value值,这样不就行了吗.
而关于倒排列表的实现是不是可以简单的用一个集合来表示呢?这样我在查男性或者女性的时候直接取出对应的集合,这样不就实现了吗?
当然,这是最简单的版本,试想下其他场景,比如对用户标签建立倒排索引,一个用户可以打上多个标签,现在需要找出标签同时为标签A和标签B的用户,应该怎么查询.
如图,我们的倒排列表是集合,首先是不是可以找到标签A和标签B各自的倒排列表,集合无序但是可以遍历,两个for循环遍历两个倒排列表便可以求出其中即属于标签A又属于标签B的用户了。假设两个倒排列表的长度分别是m,n,那么这样的时间复杂度将会是O(m*n).
能不能优化呢?可以.
如上图所示,如果将倒排列表设计成有序链表,那么是不是可以用归并排序的方式来遍历两个列表,这样时间复杂度是O(m+n),链表查询是快了,但是我们在往倒排列表中插入数据时,还得判断数据是不是已经存在链表中,这样就得遍历整个链表,能不能优化这个过程呢?可以.
我们遍历无非就是要找到这个数据是不是已经在倒排列表中了,如果在的话,我就不插入链表了.
那么我们在最初插入链表时,除了将数据插入链表,还要再将数据插入到一个hash或者集合里,等到后续再插入数据的时候,首先查看map里是否存在相同数据,相同则不进行接下来的插入工作,这样是不是可以优化掉一部分链表的无效遍历了。并且如果将倒排链表设计成双向链表,在删除的时候也可以先查看hash结构查找到需要删除的节点,然后直接根据节点的前后指针,便可以在O(1)的时间复杂度完成删除操作。 如图
好了,说了这么多,关于内存上如何实现一个倒排索引,我觉得大家完全可以发挥自己的想象,在不同的场景下选择不同的数据结构进行组装,便能很轻松的实现一个基于内存的倒排索引。接下来,我们来看看,当倒排索引越来越大,大到内存放不下的时候,我们又该怎么做.
既然是数据存储,必然倒排索引会有内存不能完全放下的一天,这个时候,想想看,有没有什么办法能在磁盘上很好的表示一个倒排索引结构?
内存上可以用hashmap来存储词典的key值,但是我们应该如何将词典存在磁盘上呢,还记得之前提到过的b+tree( 看了还不懂b+tree本质就来打我 )吗,它能很好的应对磁盘随机读的情况,正好可以拿来应用到词典对key值的查询上.
那么如何来实现倒排列表呢? 既然存在磁盘上,那是不是也可以用b+tree存储呢?其实也是可以的,不过这样的设计会导致读取倒排列表不会按文档id递增读取,并且由于倒排列表不是递增,那么在多条件查询时,将不能用多路归并的方法进行文档id的合并,提高了查询时间复杂度.
既然这样,那我们就将数据结构设计成顺序的好了,还记得前面实现内存上的倒排列表时采用的什么数据结构吗,有序链表。那么是不是可以直接将数据顺序写入到磁盘就行了,比如按文档id是int类型且占8个字节计算,那么每次读取按8字节的步长就可以读取每一个文档id了。我们将磁盘想像成一个超大容量的数组.
我们的倒排索引将会变成这样.
词典中的key值指向key在磁盘上的开头位置.
可以看出,如果按固定步长进行磁盘存储,其实存储的是一个有序数组的结构.这样可以很好利用磁盘顺序读写的高效性特点.
但是这样会面临倒排索引更新的问题,因为在磁盘上有序存储,如果要在这个倒排列表上新增一个文档id,那么要移动磁盘数据,这样的代价显然太大.
如果把磁盘上的数据结构变成一个有序链表呢,每次存储时按有序链表的节点进行存储,那么每个节点除了要包含文档id的8个字节,还要再包含指向下一个节点的位置。这样新增一个文档id,是不是可以往倒排列表所在的磁盘空间末尾新增一个节点的空间,然后让倒排节点的末尾节点指向新增的节点即可,不用移动磁盘数据.
这样我们的倒排索引在磁盘上就会变成下面这张图的样子,各个倒排链表之间是通过指针关联在了一起,而词典的key指向的是链表头部的元素在磁盘上的位置.
但是,又是一个但是,如果对这样的倒排列表频繁进行删除和更新会怎么样,之前在讲b+tree本质的时候,有说过由于节点的删除和更新,b+tree相邻父子节点之间只是位置相邻,在磁盘空间上可能并不相邻.
对于链表来说也是一样,频繁的插入和删除就会导致顺序的数据在磁盘上可能分布在不同磁道了,可以看到,同一个key的倒排列表在磁盘上并不相邻, 在读取倒排列表时,将会有过多的随机读产生,严重影响性能.
既然这样,能不能借鉴下LSM对索引合并的思路( 剖析LSM索引原理 ),对索引的更新采取合并的策略,而不是原地更新的方式,比如,在新增文档时,会去构建增量的词典和倒排索引,这一部分索引暂时不可见,只有等到这部分索引和历史可见索引进行合并后,才会真正被搜索到.
如图所示,同一个颜色属于同一个倒排列表.
这样虽然牺牲了一点立即可见性,但由于 合并时是写入到一个新的倒排文件里,将会是顺序写 ,同一个倒排连基本是在相同的磁道上,这样读取倒排列表时便可以有很好的读取性能.
采用索引合并的策略是不是就没有其他问题呢?它同样面临索引合并的常见问题,一个小数量级的索引和大数量级的索引进行合并时,会产生很多无效合并。新的增量的倒排索引是比较少量的,而历史的索引数量级是比较庞大的,每次由于新增的倒排索引需要合并就要去遍历整个历史的索引文件显然是划不来的.
一个比较简单的解决办法就是,直接将大的索引文件拆分成很多个小段的索引文件, 我们将这些由大索引分割的小索引文件叫做segment,每个segment是有它自己的词典和倒排列表 .
选择合并索引的策略也是选择大小相近的segment索引文件进行合并,每个小的索引文件里有各自的词典和倒排列表。这样查询的时候可能就麻烦点,需要查询多个小的索引文件,不过这样的查询完全可以采用多cpu同时并行查询进行加速。如下图所示,是将增量的倒排索引合并到存量索引的过程,合并时,只将segment2和segment3进行合并.
注意虽然将这种分割后的小词典和它的倒排列表的组合称作segment,但是segment在磁盘上并不一定是只用一个文件,我们完全可以对segment进行编号后,通过不同的后缀对不同类型的文件进行取名。如图所示
假设 文件segment1.dc代表segment1的词典,segment1.lt文件代表segment1的倒排列表。.dc后缀表明这是一个词典文件,.lt后缀表明这是存储一个倒排列表的文件.
再回到起初 词典是怎么存储在磁盘上的问题上,我们采用了b+tree结构,但是将索引分成多个小的索引文件之后,我们要想查某个词对应的倒排列表,是不是要每个小的索引文件都要去用小索引文件他们各自的b+tree词典去查一遍存不存在这个词呢?这样即使是多cpu查询,但是大量的随机读会把查询瓶颈压在磁盘上.
词典存磁盘访问慢是因为词典无法存在内存里,词典无法存储在内存上的原因是词典过于大了,所以我们得想办法压缩词典的大小.
所以,有没有什么办法能压缩词典的大小呢?
我将直接揭晓答案,采用前缀树的数据结构能很有效的将词典的体积缩小到内存能够容纳的范围。前缀树的节点包含了词中的每个字母,并且表明了从根节点到此节点上的路径是否构成了一个词典中的词。如图:
绿色的节点代表从根节点到该节点的路径上存在一个词,这颗前缀树能够代表的字母为get,go,good。比如英文字母只有26个,这样用前缀树组合形成的词语存储方式可以极大的省掉大量前缀相同的词的存储空间.
这样,每个小的索引文件(segment)便可以将词典对应的前缀树存储到内存中了。这下我们来完成倒排索引最后的架构图.
每一个segment索引文件都有自己的前缀树结构在内存中.
整个倒排索引的查询过程就变成了先查内存中的前缀树结构,找到特定的词所在segment.dl词典文件的位置,我们实现词典文件的存储采用b+tree的方式,然后通过查询词典文件,再找到具体的倒排列表的位置,我们采用有序链表顺序写入倒排列表的方式让词典中属于同一个词的倒排列表中的元素尽量相邻,提高倒排列表从磁盘读取的效率.
至此,我们实现了一个基于磁盘的倒排索引,但优化远远没有结束。例如,业界上在实现倒排列表时,为了极致的压缩存储空间,采用了一些压缩方案例如Frame of ,并且为了提高联合查询效率,将倒排链表设计成跳表,将倒排列表查询结果缓存起来等等。希望我的文章能抛砖引玉,引发大家更多的思考.
创作不易,如果觉得我的文章对你有帮助,关注一下,点个赞吧😄.
最后此篇关于甩出11张图-让我们来构想(实现)一个倒排索引的文章就讲到这里了,如果你想了解更多关于甩出11张图-让我们来构想(实现)一个倒排索引的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我在使用带有 vector STL 的迭代器时遇到了这个错误。 代码:- #include #include void print_vec(std::vector vec) { auto
JAVA:两个引用“p”&&“pp”之间有区别吗? PrintStream p = new PrintStream(System.out); p.println("lol");
我尝试从主分支中拉出,但收到错误消息: $ git --no-optional-locks -c color.branch=false -c color.diff=false -c color.sta
我面临着一个让我抓狂的问题! 我有一个函数,这个: void load_weapons3(t_env *e, char *name, int x, t_weapon *w) { char
我正在尝试使用 CUDA 中的最小值、最大值、总和和平均值实现并行归约。 这是我目前的主要代码片段。 int main() { const auto count = 8; const
我知道 double free 或 corruption 错误通常是对 big 3 的违规,但在这种情况下,我找不到违规发生的地方。我有一个复制构造函数、析构函数和赋值运算符,适用于任何处理指针的东西
GTK+ 中的“focus”和“focus-in(out)-event”信号有什么区别?哪个先发射?它们与键盘(TAB)和鼠标点击有什么关系。他们互相依赖吗? 我问这个是因为我想在顶层窗口中跟踪当前聚
*** glibc detected *** /home/ghoshs/workspace/Simulator/Debug/Simulator: double free or corruption (
#include #include #include #include using namespace std; #define MAX_WEIGHT 1000000 class Set {
我在服务器上有两个分支一个叫 R2 的分支和一个叫 DEV 的分支我无意中登录了错误的服务器,进入了存储库并执行了GIT pull 源开发但是存储库在 R2 上。所以我意识到我的错误然后尝试通过做一个
我有一个包含循环的大约 1000 个顶点和 3000 个边的有向图。 我试图从给定的顶点找到所有下游(出)路径。 使用以下 Gremlin 查询时 g.V(45712).repeat(out().si
使用 Delphi XE 2 我试图确定缩放方向以将缩放效果应用于图像(TImage),但没有找到执行此操作的函数,并且图像的 OnGesture 事件中的 EventInfo 属性没有此信息. 我见
我正在尝试创建一个 Zoom_image 函数,它使用离散傅里叶变换来缩放灰度图像。如果图像大小小于或等于 4*4 但大小增加,我包含的代码可以工作。它给出“双重释放或损坏(出)中止(核心转储)”错误
当我执行 popAll 函数时,出现以下错误: 双重释放或腐败(出)中止(核心转储) 我想我已经将错误来源缩小到了这个函数。 IntegerStack 是我制作的一个简单的 ADT,其中包含一个名为
我有网络开发背景,我正在尝试创建类似于 this technique 的东西适用于 iOS(使用 Cocoa/Obj C)。我在谷歌搜索资源时遇到了很多困难,因为 iOS 中的“视差”往往指的是 iO
我想实现一个 faceted search对于我的一个项目。我正在使用 PHP5、Mysql 和 Symfony 1.4。显然社区指向Apache Solr这似乎正是我想要完成的。 问题是该网站将在不
我知道有 questions floating around当您没有提供明确的分支名称时,关于来自特定分支的 git pull,但是我想知道即使用户确实指定了不同的分支,是否也可以强制 pull 分支
我正在尝试将我的更改推送到 NAS 上的存储库。它以我无法理解的方式失败。 documentation声明默认情况下 push 仅适用于快进更新。很公平。所以我做了一个 git pull(我的 Rem
我刚开始使用 Oracle 的 Coherence 缓存,我注意到这一点:如果我在缓存中放入一个 ConcurrentHashMap 对象,当我检索它时,我可以看到它被转换为一个普通的 HashMap
我尝试创建一个连接到数据库的线程,从那里获取一些数据并打印到控制台。问题是当该线程完成时抛出异常: 双重免费或腐败(出局)中止(核心转储) 我尝试使用 sqlite3 和 pthread,但这两个并不
我是一名优秀的程序员,十分优秀!