From ca18a9b5e12a391ce80987074edd58bc651275e7 Mon Sep 17 00:00:00 2001 From: Tomoyuki Morita Date: Mon, 24 Feb 2025 17:43:28 -0800 Subject: [PATCH] Remove OpenSearchRequestBuilder.buildRequestWithScroll Signed-off-by: Tomoyuki Morita --- .../request/OpenSearchRequestBuilder.java | 26 ------------------- 1 file changed, 26 deletions(-) diff --git a/opensearch/src/main/java/org/opensearch/sql/opensearch/request/OpenSearchRequestBuilder.java b/opensearch/src/main/java/org/opensearch/sql/opensearch/request/OpenSearchRequestBuilder.java index b919c0845b..2249080324 100644 --- a/opensearch/src/main/java/org/opensearch/sql/opensearch/request/OpenSearchRequestBuilder.java +++ b/opensearch/src/main/java/org/opensearch/sql/opensearch/request/OpenSearchRequestBuilder.java @@ -132,32 +132,6 @@ private OpenSearchRequest buildRequestWithPit( } } - private OpenSearchRequest buildRequestWithScroll( - OpenSearchRequest.IndexName indexName, int maxResultWindow, TimeValue cursorKeepAlive) { - int size = requestedTotalSize; - FetchSourceContext fetchSource = this.sourceBuilder.fetchSource(); - List includes = fetchSource != null ? Arrays.asList(fetchSource.includes()) : List.of(); - - if (pageSize == null) { - if (startFrom + size > maxResultWindow) { - sourceBuilder.size(maxResultWindow - startFrom); - return new OpenSearchScrollRequest( - indexName, cursorKeepAlive, sourceBuilder, exprValueFactory, includes); - } else { - sourceBuilder.from(startFrom); - sourceBuilder.size(requestedTotalSize); - return new OpenSearchQueryRequest(indexName, sourceBuilder, exprValueFactory, includes); - } - } else { - if (startFrom != 0) { - throw new UnsupportedOperationException("Non-zero offset is not supported with pagination"); - } - sourceBuilder.size(pageSize); - return new OpenSearchScrollRequest( - indexName, cursorKeepAlive, sourceBuilder, exprValueFactory, includes); - } - } - private String createPit( OpenSearchRequest.IndexName indexName, TimeValue cursorKeepAlive, OpenSearchClient client) { // Create PIT ID for request