Skip to content

Commit f1b4a54

Browse files
authored
Add scrolltime condition when using SearchRequest.
Original Pull Request #1975 Closes #1974
1 parent c37bbd5 commit f1b4a54

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java

+8
Original file line numberDiff line numberDiff line change
@@ -1029,6 +1029,10 @@ private SearchRequest prepareSearchRequest(Query query, @Nullable Class<?> clazz
10291029
sourceBuilder.runtimeMappings(runtimeMappings);
10301030
}
10311031

1032+
if (query.getScrollTime() != null) {
1033+
request.scroll(TimeValue.timeValueMillis(query.getScrollTime().toMillis()));
1034+
}
1035+
10321036
request.source(sourceBuilder);
10331037

10341038
return request;
@@ -1131,6 +1135,10 @@ private SearchRequestBuilder prepareSearchRequestBuilder(Query query, Client cli
11311135
searchRequestBuilder.setRuntimeMappings(runtimeMappings);
11321136
}
11331137

1138+
if (query.getScrollTime() != null) {
1139+
searchRequestBuilder.setScroll(TimeValue.timeValueMillis(query.getScrollTime().toMillis()));
1140+
}
1141+
11341142
return searchRequestBuilder;
11351143
}
11361144

0 commit comments

Comments
 (0)