queryRequestBuilder.setPreference(Constants.SEARCH_PREFERENCE_LOCAL);
            return true;
        }, (queryRequestBuilder, execTime, searchResponse) -> {
            final List<Map<String, String>> sessionIdList = new ArrayList<>();
            searchResponse.ifPresent(response -> {
                final Terms terms = response.getAggregations().get(fessConfig.getIndexFieldSegment());

                            .responseFields(queryFieldConfig.getScrollResponseFields())
                            .searchRequestType(params.getType())
                            .build();
                }, (searchResponse, hit) -> {
                    final Map<String, Object> docMap = new HashMap<>();
                    final Map<String, Object> source = hit.getSourceAsMap();
                    if (source != null) {

import org.opensearch.action.bulk.BulkItemResponse;
import org.opensearch.action.bulk.BulkItemResponse.Failure;
import org.opensearch.action.bulk.BulkResponse;
import org.opensearch.action.search.SearchResponse;
import org.opensearch.index.query.QueryBuilder;
import org.opensearch.index.query.QueryBuilders;

/**
 * Helper class for indexing operations in the Fess search engine.