Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for sendDocuments (0.07 sec)

  1. src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java

                }
    
                if (docList.getContentSize() >= maxDocumentRequestSize || docList.size() >= maxDocumentCacheSize) {
                    indexingHelper.sendDocuments(searchEngineClient, docList);
                }
                executeTime += processingTime;
            }
    
            documentSize.getAndIncrement();
    
            if (logger.isDebugEnabled()) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImplTest.java

            }
        }
    
        private static class TestIndexingHelper extends IndexingHelper {
            int sendDocumentsCalled = 0;
            long documentSize = 1000;
    
            @Override
            public void sendDocuments(SearchEngineClient searchEngineClient, DocList docList) {
                sendDocumentsCalled++;
                docList.clear();
            }
    
            @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 24.5K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/helper/IndexingHelperTest.java

                    return Collections.emptyList();
                }
            };
            ComponentUtil.register(client, "searchEngineClient");
            final DocList docList = new DocList();
            indexingHelper.sendDocuments(client, docList);
            assertEquals(0, docList.size());
            assertEquals(0, sentDocList.size());
            assertNull(sentIndex.get());
    
            sentIndex.set(null);
            sentDocList.clear();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 19 23:49:30 UTC 2025
    - 29.3K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

                            hitCount = ((OpenSearchResultList<OpenSearchAccessResult>) arList).getTotalHits();
                        }
                        if (!docList.isEmpty()) {
                            indexingHelper.sendDocuments(searchEngineClient, docList);
                        }
    
                        synchronized (finishedSessionIdList) {
                            if (sessionIdListSize != 0 && sessionIdListSize == finishedSessionIdList.size()) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 32.7K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/IndexingHelper.java

         * @param docList the list of documents to be indexed
         * @throws SearchEngineClientException if the bulk indexing operation fails
         */
        public void sendDocuments(final SearchEngineClient searchEngineClient, final DocList docList) {
            if (docList.isEmpty()) {
                return;
            }
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 26.1K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/indexer/IndexUpdaterTest.java

                return componentAvailable;
            }
        }
    
        private static class TestIndexingHelper extends IndexingHelper {
            @Override
            public void sendDocuments(SearchEngineClient client, DocList docList) {
                docList.clear();
            }
    
            @Override
            public long calculateDocumentSize(Map<String, Object> map) {
                return 100L;
            }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 33K bytes
    - Viewed (0)
Back to top