- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for insertAll (0.03 sec)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlFilterService.java
esUrlFilter.setSessionId(sessionId); esUrlFilter.setFilterType(INCLUDE); esUrlFilter.setUrl(url); urlFilterList.add(esUrlFilter); } insertAll(urlFilterList, OpType.INDEX); includeFilterCache.invalidate(sessionId); } /** * Adds an exclude URL filter for the specified session. * * @param sessionId The session ID.
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:40:57 UTC 2025 - 9K 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: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:40:57 UTC 2025 - 34.3K 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: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 11.1K 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: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:40:57 UTC 2025 - 16.9K bytes - Viewed (1)