Skip to content

Commit 2b3f173

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

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
@@ -1173,6 +1173,10 @@ private SearchRequest prepareSearchRequest(Query query, @Nullable Class<?> clazz
11731173
request.routing(query.getRoute());
11741174
}
11751175

1176+
if (query.getScrollTime() != null) {
1177+
request.scroll(TimeValue.timeValueMillis(query.getScrollTime().toMillis()));
1178+
}
1179+
11761180
request.source(sourceBuilder);
11771181
return request;
11781182
}
@@ -1248,6 +1252,10 @@ private SearchRequestBuilder prepareSearchRequestBuilder(Query query, Client cli
12481252
searchRequestBuilder.setRouting(query.getRoute());
12491253
}
12501254

1255+
if (query.getScrollTime() != null) {
1256+
searchRequestBuilder.setScroll(TimeValue.timeValueMillis(query.getScrollTime().toMillis()));
1257+
}
1258+
12511259
return searchRequestBuilder;
12521260
}
12531261

0 commit comments

Comments
 (0)