Skip to content

Commit c1ab4d6

Browse files
leejongchansothawo
authored andcommitted
Add scrolltime condition when using SearchRequest.
Original Pull Request #1975 Closes #1974 (cherry picked from commit f1b4a54)
1 parent 42cbab7 commit c1ab4d6

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

Diff for: src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java

+8
Original file line numberDiff line numberDiff line change
@@ -1066,6 +1066,10 @@ private SearchRequest prepareSearchRequest(Query query, @Nullable Class<?> clazz
10661066

10671067
query.getRescorerQueries().forEach(rescorer -> sourceBuilder.addRescorer(getQueryRescorerBuilder(rescorer)));
10681068

1069+
if (query.getScrollTime() != null) {
1070+
request.scroll(TimeValue.timeValueMillis(query.getScrollTime().toMillis()));
1071+
}
1072+
10691073
request.source(sourceBuilder);
10701074
return request;
10711075
}
@@ -1154,6 +1158,10 @@ private SearchRequestBuilder prepareSearchRequestBuilder(Query query, Client cli
11541158

11551159
query.getRescorerQueries().forEach(rescorer -> searchRequestBuilder.addRescorer(getQueryRescorerBuilder(rescorer)));
11561160

1161+
if (query.getScrollTime() != null) {
1162+
searchRequestBuilder.setScroll(TimeValue.timeValueMillis(query.getScrollTime().toMillis()));
1163+
}
1164+
11571165
return searchRequestBuilder;
11581166
}
11591167

0 commit comments

Comments
 (0)