- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for insertAll (0.05 sec)
-
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) -
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) -
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) -
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)