- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for sendDocuments (0.05 seconds)
-
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(); } @OverrideCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 24.7K bytes - Click Count (0) -
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; }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 33.6K bytes - Click Count (0) -
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();Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 26.1K bytes - Click Count (0) -
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()) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 10.5K bytes - Click Count (0) -
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();
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 29.7K bytes - Click Count (0) -
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()) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 32.9K bytes - Click Count (0)