Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 45 for BulkRequestBuilder (0.05 sec)

  1. src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsRelatedQueryBhv.java

            return batchInsert(list, null, null);
        }
    
        public int[] batchInsert(List<RelatedQuery> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<RelatedQuery> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/opensearch/log/bsbhv/BsFavoriteLogBhv.java

            return batchInsert(list, null, null);
        }
    
        public int[] batchInsert(List<FavoriteLog> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<FavoriteLog> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/opensearch/user/bsbhv/BsGroupBhv.java

            return batchInsert(list, null, null);
        }
    
        public int[] batchInsert(List<Group> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<Group> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsScheduledJobBhv.java

            return batchInsert(list, null, null);
        }
    
        public int[] batchInsert(List<ScheduledJob> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<ScheduledJob> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractBehavior.java

            private final List<E> parent;
    
            private final RequestOptionCall<BulkRequestBuilder> call;
    
            private final RequestOptionCall<B> entityCall;
    
            public BulkList(final List<E> parent, final RequestOptionCall<BulkRequestBuilder> call, final RequestOptionCall<B> entityCall) {
                this.parent = parent;
                this.entityCall = entityCall;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 27 07:01:25 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/opensearch/user/bsbhv/BsUserBhv.java

            return batchInsert(list, null, null);
        }
    
        public int[] batchInsert(List<User> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<User> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 12K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java

                            break;
                        }
    
                        final BulkRequestBuilder bulkRequestBuilder = client.prepareBulk();
                        Stream.of(hits).map(SearchHit::getId).forEach(id -> bulkRequestBuilder.add(new DeleteRequest(index, id)));
    
                        final BulkResponse bulkResponse = bulkRequestBuilder.execute().actionGet(settings.getBulkTimeout());
                        if (bulkResponse.hasFailures()) {
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Sun Nov 23 11:21:40 UTC 2025
    - 17.5K bytes
    - Viewed (1)
  8. src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java

            private final List<E> parent;
    
            private final RequestOptionCall<BulkRequestBuilder> call;
    
            private final RequestOptionCall<B> entityCall;
    
            public BulkList(final List<E> parent, final RequestOptionCall<BulkRequestBuilder> call, final RequestOptionCall<B> entityCall) {
                this.parent = parent;
                this.entityCall = entityCall;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 27 07:01:25 UTC 2025
    - 26.4K bytes
    - Viewed (0)
  9. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java

            final SearchHits mockScrollHits = mock(SearchHits.class);
            final ActionFuture<SearchResponse> mockScrollFuture = mock(ActionFuture.class);
    
            final BulkRequestBuilder mockBulkBuilder = mock(BulkRequestBuilder.class);
            final BulkResponse mockBulkResponse = mock(BulkResponse.class);
            final ActionFuture<BulkResponse> mockBulkFuture = mock(ActionFuture.class);
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:44:44 UTC 2025
    - 17K bytes
    - Viewed (0)
  10. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

    import org.codelibs.fess.crawler.service.UrlQueueService;
    import org.codelibs.fess.crawler.util.OpenSearchCrawlerConfig;
    import org.opensearch.action.DocWriteRequest.OpType;
    import org.opensearch.action.bulk.BulkRequestBuilder;
    import org.opensearch.action.bulk.BulkResponse;
    import org.opensearch.action.search.SearchResponse;
    import org.opensearch.action.support.WriteRequest.RefreshPolicy;
    import org.opensearch.action.update.UpdateRequestBuilder;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:40:57 UTC 2025
    - 16.9K bytes
    - Viewed (1)
Back to top