* @return the number of documents processed
     * @throws InvalidQueryException if the query is invalid
     */
    public long scrollSearch(final String index, final SearchCondition<SearchRequestBuilder> condition,
            final BooleanFunction<Map<String, Object>> cursor) {
        return scrollSearch(index, condition, getDefaultEntityCreator(), cursor);
    }

    /**

        }

        final long startTime = System.currentTimeMillis();

        try {
            final AtomicLong processedCount = new AtomicLong(0);
            final long count = searchEngineClient.scrollSearch(fessConfig.getIndexDocumentSearchIndex(), requestBuilder -> {
                requestBuilder.setQuery(query).setSize(scrollSize);
                return true;
            }, source -> {

        final JsonRequestParams params = new JsonRequestParams(request, fessConfig);
        try {
            response.setContentType("application/x-ndjson; charset=UTF-8");
            final long count = searchHelper.scrollSearch(params, doc -> {
                buf.setLength(0);
                buf.append('{');
                boolean first2 = true;
                for (final Map.Entry<String, Object> entry : doc.entrySet()) {