Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for insertAll (0.04 sec)

  1. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlFilterService.java

                esUrlFilter.setFilterType(INCLUDE);
                esUrlFilter.setUrl(url);
                urlFilterList.add(esUrlFilter);
                invalidateSet.add(sessionId);
            }
            insertAll(urlFilterList, OpType.INDEX);
            invalidateSet.forEach(s -> includeFilterCache.invalidate(s));
        }
    
        /**
         * Adds an exclude URL filter for the specified session.
         *
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

         * @param opType The operation type (CREATE, INDEX, etc.).
         * @throws OpenSearchAccessException if the bulk insertion fails.
         */
        protected <T> void insertAll(final List<T> list, final OpType opType) {
            insertAll(list, opType, false);
        }
    
        /**
         * Inserts multiple documents into the OpenSearch index using bulk operations.
         *
         * @param <T> The type of objects to insert.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 34.2K bytes
    - Viewed (0)
  3. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java

         *
         * @param accessResultList The list of access results to update.
         */
        @Override
        public void update(final List<OpenSearchAccessResult> accessResultList) {
            insertAll(accessResultList, OpType.INDEX);
        }
    
        /**
         * Gets the count of access results for a specific session.
         *
         * @param sessionId The session ID.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

                } else if (logger.isDebugEnabled()) {
                    logger.debug("Existed URL: Session ID: {}, UrlQueue: {}", sessionId, urlQueue);
                }
            }
            if (!targetList.isEmpty()) {
                insertAll(targetList.stream()
                        .filter(urlQueue -> StringUtil.isNotBlank(urlQueue.getSessionId()) && StringUtil.isNotBlank(urlQueue.getUrl()))
                        .collect(Collectors.toList()), OpType.CREATE, true);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17K bytes
    - Viewed (0)
Back to top