Shinsuke Sugaya <******@****.***> 1774491848 +0900

            doc.put("url", "http://example.com/bulk/" + i);
            doc.put("content", "This is test content for bulk document " + i);
            doc.put("boost", 1.0f);
            doc.put("role", "Rguest");
            documents.add(doc);
        }

        requestBody.put("documents", documents);

        // Execute bulk create

    }

    /**
     * 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.
     *

   *   <li>{@linkplain LoadingCache#refresh refreshing of entries}, including {@linkplain
   *       CacheBuilder#refreshAfterWrite automated refreshing}
   *   <li>{@linkplain LoadingCache#getAll bulk loading requests}, including {@linkplain
   *       CacheLoader#loadAll bulk loading implementations}
   * </ul>
   *
   * <p><b>Warning:</b> For any given key, every {@code loader} used with it should compute the same

     * @return The indices timeout.
     */
    public String getIndicesTimeout() {
        return timeoutSettings.indicesTimeout;
    }

    /**
     * Returns the bulk timeout.
     * @return The bulk timeout.
     */
    public String getBulkTimeout() {
        return timeoutSettings.bulkTimeout;
    }

    /**
     * Returns the cluster timeout.
     * @return The cluster timeout.

    /**
     * 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)

    /**
     * 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);

 *
 * <p>{@code Multiset} refines the specifications of several methods from {@code Collection}. It
 * also defines an additional query operation, {@link #count}, which returns the count of an
 * element. There are five new bulk-modification operations, for example {@link #add(Object, int)},
 * to add or remove multiple occurrences of an element at once, or to set the count of an element to

 *
 * <p>{@code Multiset} refines the specifications of several methods from {@code Collection}. It
 * also defines an additional query operation, {@link #count}, which returns the count of an
 * element. There are five new bulk-modification operations, for example {@link #add(Object, int)},
 * to add or remove multiple occurrences of an element at once, or to set the count of an element to