Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 45 of 45 for BulkRequestBuilder (0.13 sec)

  1. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

    import org.opensearch.action.admin.indices.segments.IndicesSegmentResponse;
    import org.opensearch.action.admin.indices.segments.PitSegmentsRequest;
    import org.opensearch.action.bulk.BulkRequest;
    import org.opensearch.action.bulk.BulkRequestBuilder;
    import org.opensearch.action.bulk.BulkResponse;
    import org.opensearch.action.delete.DeleteRequest;
    import org.opensearch.action.delete.DeleteRequestBuilder;
    import org.opensearch.action.delete.DeleteResponse;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 02:01:26 UTC 2025
    - 26.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

                final BiConsumer<Map<String, Object>, IndexRequestBuilder> options) {
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final BulkRequestBuilder bulkRequestBuilder = client.prepareBulk();
            for (final Map<String, Object> doc : docList) {
                final Object id = doc.remove(fessConfig.getIndexFieldId());
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 122.4K bytes
    - Viewed (1)
  3. src/test/java/org/codelibs/fess/suggest/SuggesterTest.java

        @Test
        public void test_indexFromDocumentReader() throws Exception {
            Client client = runner.client();
            int num = 1000;
            String indexName = "test";
    
            BulkRequestBuilder bulkRequestBuilder = client.prepareBulk();
            for (int i = 0; i < num; i++) {
                Map<String, Object> source = Collections.singletonMap("content", "test");
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Mon Nov 24 03:40:05 UTC 2025
    - 37.4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/SearchHelper.java

         * @throws InterruptedRuntimeException if the operation is interrupted
         * @throws SearchEngineClientException if the bulk update fails
         */
        public boolean bulkUpdate(final Consumer<BulkRequestBuilder> consumer) {
            final BulkRequestBuilder builder = ComponentUtil.getSearchEngineClient().prepareBulk();
            consumer.accept(builder);
            try {
                final BulkResponse response = builder.execute().get();
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Dec 20 05:56:45 UTC 2025
    - 36.3K bytes
    - Viewed (0)
  5. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

    import org.opensearch.action.admin.indices.mapping.get.GetMappingsResponse;
    import org.opensearch.action.admin.indices.refresh.RefreshResponse;
    import org.opensearch.action.bulk.BulkItemResponse;
    import org.opensearch.action.bulk.BulkRequestBuilder;
    import org.opensearch.action.bulk.BulkResponse;
    import org.opensearch.action.delete.DeleteResponse;
    import org.opensearch.action.get.GetResponse;
    import org.opensearch.action.index.IndexResponse;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:40:57 UTC 2025
    - 34.3K bytes
    - Viewed (0)
Back to top