|
52 | 52 | import static org.hamcrest.Matchers.containsString; |
53 | 53 | import static org.hamcrest.Matchers.equalTo; |
54 | 54 | import static org.hamcrest.Matchers.instanceOf; |
55 | | -import static org.hamcrest.Matchers.lessThanOrEqualTo; |
56 | 55 |
|
57 | 56 | @ESIntegTestCase.ClusterScope(minNumDataNodes = 3) |
58 | 57 | public class RRFRetrieverBuilderIT extends ESIntegTestCase { |
@@ -247,23 +246,23 @@ private void assertRRFPagination( |
247 | 246 | } |
248 | 247 | }); |
249 | 248 |
|
250 | | -// int innerFrom = Math.max(from, 0); |
251 | | -// int originalFrom = from; |
252 | | -// ElasticsearchAssertions.assertResponse(req, resp -> { |
253 | | -// assertNull(resp.pointInTimeId()); |
254 | | -// assertNotNull(resp.getHits().getTotalHits()); |
255 | | -// assertThat(resp.getHits().getTotalHits().value(), equalTo(6L)); |
256 | | -// assertThat(resp.getHits().getTotalHits().relation(), equalTo(TotalHits.Relation.EQUAL_TO)); |
257 | | -// assertThat(resp.getHits().getHits().length, lessThanOrEqualTo(maxExpectedSize)); |
258 | | -// for (int k = 0; k < Math.min(maxExpectedSize, resp.getHits().getHits().length); k++) { |
259 | | -// assertThat(resp.getHits().getAt(k).getId(), equalTo(expectedDocIds.get(k + innerFrom))); |
260 | | -// } |
261 | | -// |
262 | | -// if (originalFrom < 0) { |
263 | | -// // assertThat(source.from(), equalTo(SearchService.DEFAULT_FROM)); |
264 | | -// assertThat(resp.getHits().getHits().length, equalTo(maxExpectedSize)); |
265 | | -// } |
266 | | -// }); |
| 249 | + // int innerFrom = Math.max(from, 0); |
| 250 | + // int originalFrom = from; |
| 251 | + // ElasticsearchAssertions.assertResponse(req, resp -> { |
| 252 | + // assertNull(resp.pointInTimeId()); |
| 253 | + // assertNotNull(resp.getHits().getTotalHits()); |
| 254 | + // assertThat(resp.getHits().getTotalHits().value(), equalTo(6L)); |
| 255 | + // assertThat(resp.getHits().getTotalHits().relation(), equalTo(TotalHits.Relation.EQUAL_TO)); |
| 256 | + // assertThat(resp.getHits().getHits().length, lessThanOrEqualTo(maxExpectedSize)); |
| 257 | + // for (int k = 0; k < Math.min(maxExpectedSize, resp.getHits().getHits().length); k++) { |
| 258 | + // assertThat(resp.getHits().getAt(k).getId(), equalTo(expectedDocIds.get(k + innerFrom))); |
| 259 | + // } |
| 260 | + // |
| 261 | + // if (originalFrom < 0) { |
| 262 | + // // assertThat(source.from(), equalTo(SearchService.DEFAULT_FROM)); |
| 263 | + // assertThat(resp.getHits().getHits().length, equalTo(maxExpectedSize)); |
| 264 | + // } |
| 265 | + // }); |
267 | 266 | } |
268 | 267 |
|
269 | 268 | public void testRRFWithAggs() { |
|
0 commit comments