- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for sendDocuments (0.25 sec)
-
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()) {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
hitCount = ((EsResultList<EsAccessResult>) arList).getTotalHits(); } if (!docList.isEmpty()) { indexingHelper.sendDocuments(searchEngineClient, docList); } synchronized (finishedSessionIdList) { if (sessionIdListSize != 0 && sessionIdListSize == finishedSessionIdList.size()) {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 24.2K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/IndexingHelperTest.java
webConfig.setId(id); return OptionalEntity.of(webConfig); } }, WebConfigService.class.getCanonicalName()); } public void test_sendDocuments() { documentSizeByQuery = 0L; final AtomicReference<String> sentIndex = new AtomicReference<>(); final List<Map<String, Object>> sentDocList = new ArrayList<>();
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 23.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/IndexingHelper.java
protected int maxRetryCount = 5; protected int defaultRowSize = 100; protected long requestInterval = 500; public void sendDocuments(final SearchEngineClient searchEngineClient, final DocList docList) { if (docList.isEmpty()) { return; } final FessConfig fessConfig = ComponentUtil.getFessConfig();
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 15.6K bytes - Viewed (1)