import org.codelibs.fess.mylasta.direction.FessConfig;
import org.codelibs.fess.opensearch.client.SearchEngineClient;
import org.codelibs.fess.util.ComponentUtil;
import org.opensearch.action.bulk.BulkRequestBuilder;
import org.opensearch.action.bulk.BulkResponse;
import org.opensearch.action.search.SearchResponse;
import org.opensearch.action.update.UpdateRequestBuilder;
import org.opensearch.index.query.QueryBuilders;

    /**
     * The auto expand replicas for doc.
     */
    @Size(max = 10)
    public String autoExpandReplicasForDoc = ComponentUtil.getFessConfig().getIndexAutoExpandReplicas();

    /**
     * The flag to load bulk data during config index rebuild.
     */
    @Size(max = 10)
    public String loadBulkData;

    /**
     * The flag to rebuild fess_config indices.
     */
    @Size(max = 10)

    }

    /**
     * Executes a bulk request asynchronously.
     *
     * @param request the bulk request
     * @return a future for the bulk response
     */
    @Override
    public ActionFuture<BulkResponse> bulk(final BulkRequest request) {
        return client.bulk(request);
    }

    /**
     * Executes a bulk request asynchronously with a callback.
     *

    /**
     * Represents an API response for bulk operations, containing a list of processed items.
     */
    public static class ApiBulkResponse extends ApiResponse {
        /**
         * Constructs an empty ApiBulkResponse.
         */
        public ApiBulkResponse() {
            // NOP
        }

        /**
         * The list of items processed in the bulk operation.
         */

        assertEquals(1, testClient.insertBulkDataCalls.size());
        assertFalse(testClient.lastCreateOnly);
    }

    @Test
    public void test_insertBulkData_createOnlyTrue() {
        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        testClient.insertBulkData(fessConfig, "fess_config.scheduled_job", "test.bulk", true);

import org.codelibs.fess.util.DocList;
import org.codelibs.fess.util.MemoryUtil;
import org.opensearch.action.admin.indices.refresh.RefreshResponse;
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;

/**
 * Implementation of IndexUpdateCallback for handling document indexing operations.
 * This class manages the process of updating the search index with documents from
 * data stores, including bulk operations, document transformation, and error handling.
 */
public class IndexUpdateCallbackImpl implements IndexUpdateCallback {
    private static final Logger logger = LogManager.getLogger(IndexUpdateCallbackImpl.class);

        // Log the result
        if (sizeBeforeDeletion > 0) {
            logger.info("Successfully deleted {} crawling info log(s) using bulk delete", sizeBeforeDeletion);
        } else {
            logger.info("No crawling info logs to delete (may have been deleted by previous test)");
        }
    }

labels.boost=Boost
labels.crawlingConfigName=Name
labels.crawlingConfigPath=Path to Crawl
labels.processType=Process Type
labels.parameters=Parameters
labels.designFile=File to Upload
labels.bulkFile=Bulk File
labels.appendQueryParameter=Append Search Parameters
labels.configId=Config ID
labels.configParameter=Config Parameter
labels.content=Content
labels.csvFileEncoding=CSV Encoding
labels.defaultLabelValue=Default Label

     * @param thumbnailId The thumbnail ID.
     * @param value The thumbnail value to update.
     */
    protected void updateThumbnailField(final String thumbnailId, final String value) {
        // TODO bulk
        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        try {
            ComponentUtil.getIndexingHelper()