Как сгенерировать elasti c для поиска вложенных агрегатов в java?

Question

У меня есть приведенный ниже запрос агрегации, который мне нужно перевести в java

Ниже запрос агрегации необходимо перевести в java, используя elasti c клиент поиска RestHighLevelCleint, не уверен, что пытался несколько раз, но java код не может перевести согласно приведенному ниже запросу.

{
  "aggs": {
    "recommendations": {
      "nested": {
        "path": "events.recommendationData"
      },
      "aggs": {
        "exception": {
          "filter": {
            "terms": {
              "events.recommendationData.exceptionId": [
                "2"
              ]
            }
          },
          "aggs": {
            "exceptionIds": {
              "terms": {
                "field": "events.recommendationData.exceptionId.keyword",
                "size": 10
              },
              "aggs": {
                "recommendations": {
                  "nested": {
                    "path": "events.recommendationData.recommendations"
                  },
                  "aggs": {
                    "recommendationType": {
                      "terms": {
                        "field": "events.recommendationData.recommendations.recommendationType",
                        "size": 10
                      }
                    }
                  }
                }
              }
            }
          }
        }
      }
    }
  }
}

с использованием приведенного ниже кода с RestHighLevelClient

AggregationBuilder recommendations =
                AggregationBuilders.nested("recommendations", "events.recommendationData");

        AggregationBuilder exception = AggregationBuilders
                    .filter("exception", QueryBuilders.termsQuery("events.recommendationData.exceptionId", "2"));

        AggregationBuilder exceptionIds = AggregationBuilders.terms("exceptionIds")
                .field("events.recommendationData.exceptionId.keyword").size(10);

        AggregationBuilder recommendations2 =
                AggregationBuilders.nested("recommendations", "events.recommendationData.recommendations");

        AggregationBuilder recommendationType = AggregationBuilders.terms("recommendationType")
                .field("events.recommendationData.recommendations.recommendationType").size(10);

        AggregationBuilder build = 
                recommendations
                        .subAggregation(exception)
                        .subAggregation(exceptionIds)
                        .subAggregation(recommendations2)
                        .subAggregation(recommendationType);

, и он выдает неправильный запрос, как я написал ниже которого не работает.

{
  "aggregations": {
    "recommendations": {
      "nested": {
        "path": "events.recommendationData"
      },
      "aggregations": {
        "exception": {
          "filter": {
            "terms": {
              "events.recommendationData.exceptionId": [
                "1",
                "2"
              ],
              "boost": 1
            }
          }
        },
        "exceptionIds": {
          "terms": {
            "field": "events.recommendationData.exceptionId.keyword",
            "size": 10,
            "min_doc_count": 1,
            "shard_min_doc_count": 0,
            "show_term_doc_count_error": false,
            "order": [
              {
                "_count": "desc"
              },
              {
                "_key": "asc"
              }
            ]
          }
        },
        "recommendations": {
          "nested": {
            "path": "events.recommendationData.recommendations"
          }
        },
        "recommendationType": {
          "terms": {
            "field": "events.recommendationData.recommendations.recommendationType",
            "size": 10,
            "min_doc_count": 1,
            "shard_min_doc_count": 0,
            "show_term_doc_count_error": false,
            "order": [
              {
                "_count": "desc"
              },
              {
                "_key": "asc"
              }
            ]
          }
        }
      }
    }
  }
}

Answer 1

Ожидается: каждое агрегирование является субагрегацией к предыдущему.

Поэтому, если вы видите ожидаемый запрос, recommendationType является субагрегацией recommendations2. Они вместе являются субагрегацией до exceptionIds и так далее. Поэтому здесь нужно изменить только одну строку, вместо

 AggregationBuilder build = 
                recommendations
                        .subAggregation(exception)
                        .subAggregation(exceptionIds)
                        .subAggregation(recommendations2)
                        .subAggregation(recommendationType);

используйте это,

recommendations.subAggregation(
        exception.subAggregation(
            exceptionIds.subAggregation(
                recommendations2.subAggregation(recommendationType)
            )
        )
    );