@@ -132,32 +132,6 @@ private OpenSearchRequest buildRequestWithPit(
132132 }
133133 }
134134
135- private OpenSearchRequest buildRequestWithScroll (
136- OpenSearchRequest .IndexName indexName , int maxResultWindow , TimeValue cursorKeepAlive ) {
137- int size = requestedTotalSize ;
138- FetchSourceContext fetchSource = this .sourceBuilder .fetchSource ();
139- List <String > includes = fetchSource != null ? Arrays .asList (fetchSource .includes ()) : List .of ();
140-
141- if (pageSize == null ) {
142- if (startFrom + size > maxResultWindow ) {
143- sourceBuilder .size (maxResultWindow - startFrom );
144- return new OpenSearchScrollRequest (
145- indexName , cursorKeepAlive , sourceBuilder , exprValueFactory , includes );
146- } else {
147- sourceBuilder .from (startFrom );
148- sourceBuilder .size (requestedTotalSize );
149- return new OpenSearchQueryRequest (indexName , sourceBuilder , exprValueFactory , includes );
150- }
151- } else {
152- if (startFrom != 0 ) {
153- throw new UnsupportedOperationException ("Non-zero offset is not supported with pagination" );
154- }
155- sourceBuilder .size (pageSize );
156- return new OpenSearchScrollRequest (
157- indexName , cursorKeepAlive , sourceBuilder , exprValueFactory , includes );
158- }
159- }
160-
161135 private String createPit (
162136 OpenSearchRequest .IndexName indexName , TimeValue cursorKeepAlive , OpenSearchClient client ) {
163137 // Create PIT ID for request
0 commit comments