solr 打分和排序机制(转载)

以下来自solr in action。

包含:

  • 词项频次。查询词项出现在当前查询文档中的次数。
  • 反向文档频次。查询词项出现在所有文档总的次数。
  • 此项权重。
  • 标准化因子:
    • 字段规范:
      • 文档权重。
      • 字段权重。
      • 长度归一化。消除长文档的优势。因为长文档的词项频次一般会比较大。
    • 协调因子。避免一个文档中出现某一个词项的次数太多导致总分值太大。目的是让结果中包含更多的是出现所有词项的文档。

具体说明见下文。

以下转载自网络。原文地址: http://tec.5lulu.com/detail/110d8n2ehpg2j85ec.html

简述

 

内容的相似性计算由搜索引擎的几种常见的检索模型有:

向量空间模型

    简述中介绍了好多种相似性计算方法,    Solr的索引文件中有.tvx,.tvd,tvf存储了term vector的信息,首先我们学习如何利用term vector来反映相似性程度。

 

    v(d1)表示了term d1term向量,termterm    给定一个查询以及一个文档,如何计算他们的相似值呢,请看以下公式,它使用了以下概念:term frequency (tf), inverse document frequency (idf), term boosts (t.getBoost), field normalization (norm), coordination factor (coord), and query normalization (queryNorm). 

 

  • tf(t in d ) 表示该idf(t) 表示 t.getBoost() 也叫此项权重。标准化因子,它包括三个参数:
  • :此值越大,说明此文档越重要。也叫文档权重。:此域越大,说明此域越重要。也叫字段权重。:一个域中包含的总数越多(我理解的是所有这个文档的所有,而不局限于查询中的),也即文档越长,此值越小,文档越短,此值越大。也叫长度归一化。目的是消除长字段的优势。

coord(q,d):一次搜索可能包含多个搜索词,而一篇文档中也可能包含多个搜索词,此项表示,当一篇文档中包含的搜索词越多,则此文档则打分越高 ,numTermsInDocumentFromQuery / numTermsInQuery 

queryNorm(q):计算每个查询条目的方差和,此值并不影响排序,而仅仅使得不同的query之间的分数可以比较。

ps:理解到这里就可以了,下面的细节可以以后再研究。

3评分机制

表示匹配文章的程度,如果在一篇文章中该出现了次数越多,说明该对该文章的重要性越大,因而更加匹配。相反的出现越少说明该越不匹配文章。但是这里需要注意,出现次数与重要性并不是成正比的,比如出现次,出现次,对于该文章的重要性并不是倍,所以这里的值进行平方根计算。

tf(t in d) = numTermOccurrencesInDocument 1/2

  • idf, 表示包含该文章的个数,与tf不同,idf 越大表明该term越不重要。比如this很多文章都包含,但是它对于匹配文章帮助不大。这也如我们程序员所学的技术,对于程序员本身来说,这项技术掌握越深越好(掌握越深说明花时间看的越多,tf越大),找工作时越有竞争力。然而对于所有程序员来说,这项技术懂得的人越少越好(懂得的人少df小),找工作越有竞争力。人的价值在于不可替代性就是这个道理。

    idf(t) = 1 + log (numDocs / (docFreq +1)) 

  • t.getBoostboost是人为给term提升权重的过程,我们可以在IndexQuery中分别加入term boost,但是由于Query过程比较灵活,所以这里介绍给Query boostterm boost 不仅可以对Pharse进行,也可以对单个term进行,在查询的时候用^后面加数字表示:
  • title:(solr in action)^2.5  solr in action 这个pharse设置boost
  • title:(solr in action)  默认的boost1.0
  • title:(solr^2in^.01action^1.5)^3OR"solrinaction"^2.5 
  • norm(t,d) field norm,它包含Document boostField boostlengthNorm。相比于t.getBoost()可以在查询的时候进行动态的设置,norm里面的f.getBoost()d.getBoost()只能建索引过程中设置,如果需要对这两个boost进行修改,那么只能重建索引。他们的值是存储在.nrm文件中。

    norm(t,d) = d.getBoost() • lengthNorm(f) • f.getBoost() 

  • d.getBoost() documentboost,对document设置boost是通过对每一个field设置boost实现的。
  • f .getBoost() fieldboost,这里需要提以下,Solr是支持多值域方式建索引的,即同一个field多个value,如以下代码。当一个文档里出现同名的多值域时候,倒排索引和项向量都会在逻辑上将这些域的词汇单元附加进去。当对多值域进行存储的时候,它们在文档中的存储顺序是分离的,因此当你在搜索期间对文档进行检索时,你会发现多个Field实例。如下图例子所示,当查询authorLucene时候出现两个author域,这就是所谓的多值域现象。 
  • Document doc = new Document();
  • for (String author : authors){
  • doc.add(new Field("author",author,Field.Store.YES,Field.Index.ANALYZED));
  • }
  •  
  • //首先对多值域建立索引
  • Directory dir = FSDirectory.open(new File("/Users/rcf/workspace/java/solr/Lucene"));
  • IndexWriterConfig indexWriterConfig = new IndexWriterConfig(Version.LUCENE_48,new WhitespaceAnalyzer(Version.LUCENE_48));
  • @SuppressWarnings("resource")
  • IndexWriter writer = new IndexWriter(dir,indexWriterConfig);
  • Document doc = new Document();
  • doc.add(new Field("author","lucene",Field.Store.YES,Field.Index.ANALYZED));
  • doc.add(new Field("author","solr",Field.Store.YES,Field.Index.ANALYZED));
  • doc.add(new Field("text","helloworld",Field.Store.YES,Field.Index.ANALYZED));
  • writer.addDocument(doc);
  • writer.commit();
  • //对多值域进行查询
  • IndexReader reader = IndexReader.open(dir);
  • IndexSearcher search = new IndexSearcher(reader);
  • Query query = new TermQuery(new Term("author","lucene"));
  • TopDocs docs = search.search(query, 1);
  • Document doc = search.doc(docs.scoreDocs[0].doc);
  • for(IndexableField field : doc.getFields()){
  • System.out.println(field.name()+":"+field.stringValue());
  • }
  • System.out.print(docs.totalHits);
  • //运行结果
  • author:lucene
  • author:solr
  • text:helloworld
  • 2
  • 当对多值域设置boost的时候,那么该fieldboost最后怎么算呢?即为每一个值域的boost相乘。比如title这个field,第一次boost3.0,第二次1,第三次0.5,那么结果就是3*1*0.5.
  • Boost: (3) · (1) · (0.5) = 1.5 
  • lengthNorm, Norm的长度是fieldterm的个数的平方根的倒数,fieldterm的个数被定义为field的长度。field长度越大,Norm Field越小,说明term越不重要,反之越重要,这很好理解,在10个词的title中出现北京一次和在有200个词的正文中出现北京2次,哪个field更加匹配,当然是title
  • 最后再说明下,document boostfield boost 以及lengthNorm在存储为索引是以byte形式的,编解码过程中会使得数值损失,该损失对相似值计算的影响微乎其微。
  • queryNorm,  计算每个查询条目的方差和,此值并不影响排序,而仅仅使得不同的query之间的分数可以比较。也就说,对于同一词查询,他对所有的document的影响是一样的,所以不影响查询的结果,它主要是为了区分不同query了。

    queryNorm(q) = 1 / (sumOfSquaredWeights )

    sumOfSquaredWeights = q.getBoost()2 • ∑ ( idf(t) • t.getBoost() )

    coord(q,d),表示文档中符合查询的term的个数,如果在文档中查询的term个数越多,那么这个文档的score就会更高。

    numTermsInDocumentFromQuery / numTermsInQuery 

            比如QueryAccountantAND("SanFrancisco"OR"NewYork"OR"Paris") 

            文档A包含了上面的3term,那么coord就是3/4,如果包含了1个,则coord就是4/4

4源码

    上面介绍了相似值计算的公式,那么现在就来查看Solr实现的代码,这部分实现是在DefaultSimilarity类中。 

  1. @Override
  2. public float coord(int overlap, int maxOverlap) {
  3. return overlap / (float)maxOverlap;
  4. }
  5.  
  6. @Override
  7. public float queryNorm(float sumOfSquaredWeights) {
  8. return (float)(1.0 / Math.sqrt(sumOfSquaredWeights));
  9. }
  10.    
  11. @Override
  12. public float lengthNorm(FieldInvertState state) {
  13. final int numTerms;
  14. if (discountOverlaps)
  15. numTerms = state.getLength() - state.getNumOverlap();
  16. else
  17. numTerms = state.getLength();
  18. return state.getBoost() * ((float) (1.0 / Math.sqrt(numTerms)));
  19. }
  20.    
  21. @Override
  22. public float tf(float freq) {
  23. return (float)Math.sqrt(freq);
  24. }
  25.  
  26. @Override
  27. public float idf(long docFreq, long numDocs) {
  28. return (float)(Math.log(numDocs/(double)(docFreq+1)) + 1.0);
  29. }

    Solr计算score(q,d)的过程如下:

    1:调用IndexSearcher.createNormalizedWeight()计算queryNorm() 

  30. public Weight createNormalizedWeight(Query query) throws IOException {
  31. query = rewrite(query);
  32. Weight weight = query.createWeight(this);
  33. float v = weight.getValueForNormalization();
  34. float norm = getSimilarity().queryNorm(v);
  35. if (Float.isInfinite(norm) || Float.isNaN(norm)) {
  36. norm = 1.0f;
  37. }
  38. weight.normalize(norm, 1.0f);
  39. return weight;
  40. }

    具体实现步骤如下:

  • Weight weight = query.createWeight(this);
  • 创建BooleanWeight->new TermWeight()->this.stats = similarity.computeWeight)->this.weight = idf * t.getBoost()
  • public IDFStats(String field, Explanation idf, float queryBoost) {
  • // TODO: Validate?
  • this.field = field;
  • this.idf = idf;
  • this.queryBoost = queryBoost;
  • this.queryWeight = idf.getValue() * queryBoost; // compute query weight
  • }
  • 计算sumOfSquaredWeights
  • s = weights.get(i).getValueForNormalization()计算( idf(t) • t.getBoost() )如以下代码所示,queryWeight在上一部中计算出 
  • public float getValueForNormalization() {
  • // TODO: (sorta LUCENE-1907) make non-static class and expose this squaring via a nice method to subclasses?
  • return queryWeight * queryWeight; // sum of squared weights
  • }
  • BooleanWeight->getValueForNormalization->sum = (q.getBoost)*∑(this.weight)= (q.getBoost)*∑(idf * t.getBoost())2
  •  
  • public float getValueForNormalization() throws IOException {
  • float sum = 0.0f;
  • for (int i = 0 ; i < weights.size(); i++) {
  • // call sumOfSquaredWeights for all clauses in case of side effects
  • float s = weights.get(i).getValueForNormalization(); // sum sub weights
  • if (!clauses.get(i).isProhibited()) {
  • // only add to sum for non-prohibited clauses
  • sum += s;
  • }
  • }
  •  
  • sum *= getBoost() * getBoost(); // boost each sub-weight
  •  
  • return sum ;
  • }

       

  • 计算完整的querynorm() = 1 / Math.sqrt(sumOfSquaredWeights)); 
  • public float queryNorm(float sumOfSquaredWeights) {
  • return (float)(1.0 / Math.sqrt(sumOfSquaredWeights));
  • }
  • weight.normalize(norm, 1.0f) 计算norm()
  • topLevelBoost *= getBoost();   
  • 计算value = idf()*queryWeight*queryNorm=idf()2*t.getBoost()*queryNormqueryWeight在前面已计算出) 
  • public void normalize(float queryNorm, float topLevelBoost) {
  • this.queryNorm = queryNorm * topLevelBoost;
  • queryWeight *= this.queryNorm; // normalize query weight
  • value = queryWeight * idf.getValue(); // idf for document
  • }
  •  

    2:调用IndexSearch.weight.bulkScorer()计算coord(q,d),并获取每一个termdocFreq,并将docFreqtd从小到大排序。 

  1. if (optional.size() == 0 && prohibited.size() == 0) {
  2. float coord = disableCoord ? 1.0f : coord(required.size(), maxCoord);
  3. return new ConjunctionScorer(this, required.toArray(new Scorer[required.size()]), coord);
  4. }

    3score.score()进行评分计算,获取相似值,并放入优先级队列中获取评分最高的doc id

  • weightValue= value =idf()2*t.getBoost()*queryNorm
  • sore = ∑(tf()*weightValue)*cood 计算出最终的相似值
  • 这里貌似没有用到lengthNorm 
  • public float score(int doc, float freq) {
  • final float raw = tf(freq) * weightValue; // compute tf(f)*weight
  • return norms == null ? raw : raw * decodeNormValue(norms.get(doc)); // normalize for field
  • }
  •    
  • public float score() throws IOException {
  • // TODO: sum into a double and cast to float if we ever send required clauses to BS1
  • float sum = 0.0f;
  • for (DocsAndFreqs docs : docsAndFreqs) {
  • sum += docs.scorer.score();
  • }
  • return sum * coord;
  • }
  •  
  • public void collect(int doc) throws IOException {
  • float score = scorer.score();
  •    
  • // This collector cannot handle these scores:
  • assert score != Float.NEGATIVE_INFINITY;
  • assert !Float.isNaN(score);
  •    
  • totalHits++;
  • if (score <= pqTop.score) {
  • // Since docs are returned in-order (i.e., increasing doc Id), a document
  • // with equal score to pqTop.score cannot compete since HitQueue favors
  • // documents with lower doc Ids. Therefore reject those docs too.
  • return;
  • }
  • pqTop.doc = doc + docBase;
  • pqTop.score = score;
  • pqTop = pq.updateTop();
  • }

5公式推导

关于公式的推导觉先的《Lucene学习总结之六:Lucene打分公式的数学推导》可以查看这部分内容。 

我们把文档看作一系列词(Term),每一个词(Term)都有一个权重(Term weight),不同的词(Term)根据自己在文档中的权重来影响文档相关性的打分计算。

于是我们把所有此文档中词(term)的权重(term weight) 看作一个向量。

Document = {term1, term2, …… ,term N}

Document Vector = {weight1, weight2, …… ,weight N}

同样我们把查询语句看作一个简单的文档,也用向量来表示。

Query = {term1, term 2, …… , term N}

Query Vector = {weight1, weight2, …… , weight N}

我们把所有搜索出的文档向量及查询向量放到一个N维空间中,每个词(term)是一维。

我们认为两个向量之间的夹角越小,相关性越大。

所以我们计算夹角的余弦值作为相关性的打分,夹角越小,余弦值越大,打分越高,相关性越大。

余弦公式如下:

 

下面我们假设:

查询向量为Vq = <w(t1, q), w(t2, q), ……, w(tn, q)>

文档向量为Vd = <w(t1, d), w(t2, d), ……, w(tn, d)>

向量空间维数为n,是查询语句和文档的并集的长度,当某个Term不在查询语句中出现的时候,w(t, q)为零,当某个Term不在文档中出现的时候,w(t, d)为零。

w代表weight,计算公式一般为tf*idf

我们首先计算余弦公式的分子部分,也即两个向量的点积:

Vq*Vd = w(t1, q)*w(t1, d) + w(t2, q)*w(t2, d) + …… + w(tn ,q)*w(tn, d)

w的公式代入,则为

Vq*Vd = tf(t1, q)*idf(t1, q)*tf(t1, d)*idf(t1, d) + tf(t2, q)*idf(t2, q)*tf(t2, d)*idf(t2, d) + …… + tf(tn ,q)*idf(tn, q)*tf(tn, d)*idf(tn, d)

在这里有三点需要指出:

  • 由于是点积,则此处的t1, t2, ……, tn只有查询语句和文档的并集有非零值,只在查询语句出现的或只在文档中出现的Term的项的值为零。
  • 在查询的时候,很少有人会在查询语句中输入同样的词,因而可以假设tf(t, q)都为1
  • idf是指Term在多少篇文档中出现过,其中也包括查询语句这篇小文档,因而idf(t, q)idf(t, d)其实是一样的,是索引中的文档总数加一,当索引中的文档总数足够大的时候,查询语句这篇小文档可以忽略,因而可以假设idf(t, q) = idf(t, d) = idf(t)

    基于上述三点,点积公式为:

    Vq*Vd = tf(t1, d) * idf(t1) * idf(t1) + tf(t2, d) * idf(t2) * idf(t2) + …… + tf(tn, d) * idf(tn) * idf(tn)

    所以余弦公式变为:

    下面要推导的就是查询语句的长度了。

    由上面的讨论,查询语句中tf都为1idf都忽略查询语句这篇小文档,得到如下公式

    所以余弦公式变为:

    下面推导的就是文档的长度了,本来文档长度的公式应该如下:

    这里需要讨论的是,为什么在打分过程中,需要除以文档的长度呢?

    因为在索引中,不同的文档长度不一样,很显然,对于任意一个term,在长的文档中的tf要大的多,因而分数也越高,这样对小的文档不公平,举一个极端的例子,在一篇1000万个词的鸿篇巨著中,"lucene"这个词出现了11次,而在一篇12个词的短小文档中,"lucene"这个词出现了10次,如果不考虑长度在内,当然鸿篇巨著应该分数更高,然而显然这篇小文档才是真正关注"lucene"的。

    然而如果按照标准的余弦计算公式,完全消除文档长度的影响,则又对长文档不公平(毕竟它是包含了更多的信息),偏向于首先返回短小的文档的,这样在实际应用中使得搜索结果很难看。

    所以在Lucene中,SimilaritylengthNorm接口是开放出来,用户可以根据自己应用的需要,改写lengthNorm的计算公式。比如我想做一个经济学论文的搜索系统,经过一定时间的调研,发现大多数的经济学论文的长度在800010000词,因而lengthNorm的公式应该是一个倒抛物线型的,8000 10000词的论文分数最高,更短或更长的分数都应该偏低,方能够返回给用户最好的数据。

    在默认状况下,Lucene采用DefaultSimilarity,认为在计算文档的向量长度的时候,每个Term的权重就不再考虑在内了,而是全部为一。

    而从Term的定义我们可以知道,Term是包含域信息的,也即title:hellocontent:hello是不同的Term,也即一个Term只可能在文档中的一个域中出现。

    所以文档长度的公式为:

    代入余弦公式:

    再加上各种boostcoord,则可得出Lucene的打分计算公式。

6总结

    前面学习了Solr的评分机制,虽然对理论的推导以及公式有了一些了解,但是在Solr具体实现上我却产生了不少疑惑:

    1. BooleanQuery查询,为什么没有用到LengthNorm

    2. BooleanQuery 多条件查询时候,Not And Or 对文档进行打分时候是否具有影响。

    3. PharseQuery查询时候,打分又是怎么进行的。

    4. 怎么样对这个进行打分进行定制。

    这些都是接下来需要去理解的。

我们习惯用自己的行为准则审视他人,并时刻准备加以指摘。
原文地址:https://www.cnblogs.com/cuihongyu3503319/p/9887549.html