Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for sendDocuments (0.25 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()) {
    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)
  2. 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)
  3. 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)
  4. 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)
Back to top