CODEWITHSUNDEEP
elasticsearchelasticsearch-painless
el n00b
el n00b

Reputation: 1863

Elasticsearch Painless calculate score from nested elements

Note: I had originally posted this question a little differently and it wasn't worth updating as after reading I learned a bit more.

Requirement

Search for documents and calculate a custom score based on nested elements within the document.

Structure

{
  "mappings": {
    "book": {
      "properties": {
        "title":        { "type": "string", "index": "not_analyzed" },
        "topics": {
          "type": "nested",
          "properties": {
            "title":   { "type": "string", "index": "not_analyzed" },
            "weight":  { "type": "int" }
          }
        }
      }
    }
  }
}

Sample Query

{
  "query": {
    "function_score": {
      "query": {
        "term": { "title": "The Magical World of Spittle" }
      },
      "script_score": {
        "script": {
          "lang": "painless",
          "inline": "int score = 0; for(int i = 0; i < doc['topics'].values.length; i++) { score += doc['topics'][i].weight; } return score;",
          "params": {
            "default_return_value": 100
          }
        }
      }
    }
  }
}

Isolated Painless

int score = 0;
for(int i = 0; i < doc['topics'].values.length; i++) {
  score += doc['topics'][i].weight;
}
return score;

The Error

No field found for [topics] in mapping with types [book]

The Questions

Upvotes: 7

Views: 2231

Answers (1)

Val
Val

Reputation: 217464

Nested documents are stored in different documents in the index, so you cannot access them via doc values from the parent document. You need to use the source document and navigate to the topics.weight property, like this:

Isolated Painless:

int score = 0; 
for(int i = 0; i < params._source['topics'].size(); i++) { 
    score += params._source['topics'][i].weight; 
}
return score;

Full query:

{
  "query": {
    "function_score": {
      "query": {
        "term": { "title": "Book 1" }
      },
      "script_score": {
        "script": {
          "lang": "painless",
          "inline": "int score = 0; for(int i = 0; i < params._source['topics'].size(); i++) { score += params._source['topics'][i].weight; } return score;",
          "params": {
            "default_return_value": 100
          }
        }
      }
    }
  }
}

PS: Also note that the type int doesn't exist, it's is integer

Upvotes: 12

Related Questions