From c1ab4d66e06587295c2157b0cc0df4df5bdeb662 Mon Sep 17 00:00:00 2001 From: jongchan lee Date: Wed, 27 Oct 2021 01:23:29 +0900 Subject: [PATCH] Add scrolltime condition when using SearchRequest. Original Pull Request #1975 Closes #1974 (cherry picked from commit f1b4a54bc23ee3944462c640966672b6310eebf8) --- .../data/elasticsearch/core/RequestFactory.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java b/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java index c3db88322..550796f25 100644 --- a/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java +++ b/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java @@ -1066,6 +1066,10 @@ class RequestFactory { query.getRescorerQueries().forEach(rescorer -> sourceBuilder.addRescorer(getQueryRescorerBuilder(rescorer))); + if (query.getScrollTime() != null) { + request.scroll(TimeValue.timeValueMillis(query.getScrollTime().toMillis())); + } + request.source(sourceBuilder); return request; } @@ -1154,6 +1158,10 @@ class RequestFactory { query.getRescorerQueries().forEach(rescorer -> searchRequestBuilder.addRescorer(getQueryRescorerBuilder(rescorer))); + if (query.getScrollTime() != null) { + searchRequestBuilder.setScroll(TimeValue.timeValueMillis(query.getScrollTime().toMillis())); + } + return searchRequestBuilder; }