List<Map<String, Object>> results = ScrollOperationHelper.scrollSearch(client, suggester.settings(), INDEX_NAME,
                QueryBuilders.matchAllQuery(), 10, (hit, accumulator) -> accumulator.add(hit.getSourceAsMap()));

        assertNotNull(results);
        assertEquals(3, results.size());

        // Verify we can access the source data
        for (Map<String, Object> result : results) {

        for (int i = 0; i < hits.length && words.size() < size; i++) {
            final SearchHit hit = hits[i];

            final Map<String, Object> source = hit.getSourceAsMap();
            final String text = source.get(FieldNames.TEXT).toString();
            if (skipDuplicateWords) {
                final String normalizedText = text.replace(" ", "");

                if (hits.length == 0) {
                    break;
                }
                for (final SearchHit hit : hits) {
                    final SuggestItem item = SuggestItem.parseSource(hit.getSourceAsMap());
                    freqSetter.accept(item);
                    item.setKinds(Stream.of(item.getKinds()).filter(kind -> kind != kindToRemove).toArray(SuggestItem.Kind[]::new));
                    updateItems.add(item);

            }, (builder, hit) -> {
                try {
                    final Map<String, Object> doc = hit.getSourceAsMap();
                    final String url = DocumentUtil.getValue(doc, fessConfig.getIndexFieldUrl(), String.class);
                    if (StringUtil.isNotBlank(url)) {

                indexRequestBuilder.setId(item.getId())
                        .setOpType(IndexRequest.OpType.INDEX)
                        .setSource(item.getUpdatedSource(getResponse.getSourceAsMap()));
                bulkRequestBuilder.add(indexRequestBuilder);
            } else {
                final IndexRequestBuilder indexRequestBuilder = new IndexRequestBuilder(client, IndexAction.INSTANCE, index);

        final List<LogNotificationEvent> events = new ArrayList<>();
        final List<String> docIds = new ArrayList<>();
        for (final SearchHit hit : hits) {
            final Map<String, Object> source = hit.getSourceAsMap();
            events.add(new LogNotificationEvent(((Number) source.get("timestamp")).longValue(), (String) source.get("level"),

            index = hits[0].getIndex();
        } else {
            index = SuggestConstants.EMPTY_STRING;
        }

        for (final SearchHit hit : hits) {
            final Map<String, Object> source = hit.getSourceAsMap();
            final String text = source.get(FieldNames.TEXT).toString();
            words.add(text);

            if (detail) {
                items.add(SuggestItem.parseSource(source));
            }