Aggregation-Unterstützung für Spring-Daten Elastic Search

Elastic search veraltet Facetten und empfehlen die Verwendung von Aggregationen (http://www.elastic.co/guide/en/elasticsearch/reference/1.x/search-aggregations.html) .

Ist Spring Data Elastic Search unterstützt diese derzeit ?

Wenn ja, gibt es irgendwelche Proben zur Verfügung ?

InformationsquelleAutor Sathish Kumar Thiyagarajan | 2015-05-12
  1. 10

    Ja-aggregation unterstützt.

    Beispiel :

        @Test
    public void shouldReturnAggregatedResponseForGivenSearchQuery() {
    //given
    IndexQuery article1 = new ArticleEntityBuilder("1").title("article four").subject("computing").addAuthor(RIZWAN_IDREES).addAuthor(ARTUR_KONCZAK).addAuthor(MOHSIN_HUSEN).addAuthor(JONATHAN_YAN).score(10).buildIndex();
    IndexQuery article2 = new ArticleEntityBuilder("2").title("article three").subject("computing").addAuthor(RIZWAN_IDREES).addAuthor(ARTUR_KONCZAK).addAuthor(MOHSIN_HUSEN).addPublishedYear(YEAR_2000).score(20).buildIndex();
    IndexQuery article3 = new ArticleEntityBuilder("3").title("article two").subject("computing").addAuthor(RIZWAN_IDREES).addAuthor(ARTUR_KONCZAK).addPublishedYear(YEAR_2001).addPublishedYear(YEAR_2000).score(30).buildIndex();
    IndexQuery article4 = new ArticleEntityBuilder("4").title("article one").subject("accounting").addAuthor(RIZWAN_IDREES).addPublishedYear(YEAR_2002).addPublishedYear(YEAR_2001).addPublishedYear(YEAR_2000).score(40).buildIndex();

    elasticsearchTemplate.index(article1);
    elasticsearchTemplate.index(article2);
    elasticsearchTemplate.index(article3);
    elasticsearchTemplate.index(article4);
    elasticsearchTemplate.refresh(ArticleEntity.class, true);

    SearchQuery searchQuery = new NativeSearchQueryBuilder()
            .withQuery(matchAllQuery())
            .withSearchType(COUNT)
            .withIndices("articles").withTypes("article")
            .addAggregation(terms("subjects").field("subject"))
            .build();
    //when
    Aggregations aggregations = elasticsearchTemplate.query(searchQuery, new ResultsExtractor<Aggregations>() {
        @Override
        public Aggregations extract(SearchResponse response) {
            return response.getAggregations();
        }
    });
    //then
    assertThat(aggregations, is(notNullValue()));
    assertThat(aggregations.asMap().get("subjects"), is(notNullValue()));
}

    code ist kopiert von ElasticsearchTemplateAggregationTests.java

    • Ich habe den gleichen aber der Teil, der Extrakt aggregation Teil nimmt erhebliche Menge an Zeit, weil meine Reaktionszeit wird immer erhöht
    InformationsquelleAutor Mohsin Husen
  2. 4

    Um zu verhindern, dass ein zweiter Aufruf von elasticsearch können Sie extrahieren Sie die serachResult direkt. 

    elasticsearchTemplate.query(query.build(), new ResultsExtractor<Object>() {
        @Override
        public Object extract(SearchResponse searchResponse) {
            Aggregations aggregations = searchResponse.getAggregations();
            List<AnyClass> ta = new DefaultResultMapper().mapResults(searchResponse, AnyClass.class, new PageRequest(page != null ? page : 0, 15)).getContent();
            return ta;
        }
    });
    InformationsquelleAutor Simon Ludwig
Schreibe einen Kommentar