- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for offerAll (0.06 seconds)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
* Only URLs that don't already exist will be added. * * @param sessionId The session ID. * @param urlQueueList The list of URL queue entries to offer. */ @Override public void offerAll(final String sessionId, final List<OpenSearchUrlQueue> urlQueueList) { if (logger.isDebugEnabled()) { logger.debug("Offering URL: Session ID: {}, UrlQueue: {}", sessionId, urlQueueList); }
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Thu Nov 20 08:40:57 GMT 2025 - 16.9K bytes - Click Count (1) -
src/test/java/org/codelibs/fess/indexer/IndexUpdaterTest.java
// Do nothing in test } @Override public void deleteAll() { // Do nothing in test } @Override public void offerAll(String sessionId, List<OpenSearchUrlQueue> list) { // Do nothing in test } @Override public OpenSearchUrlQueue poll(String sessionId) { return null; }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 33.6K bytes - Click Count (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java
urlQueue.setSessionId(sessionId); urlQueue.setUrl("http://www.example.com/page" + i); urlQueueList.add(urlQueue); } urlQueueService.offerAll(sessionId, urlQueueList); // Poll all items int count = 0; while (true) { final OpenSearchUrlQueue polled = urlQueueService.poll(sessionId); if (polled == null) {
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Wed Jan 14 23:48:16 GMT 2026 - 14.5K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Wed Dec 31 09:07:38 GMT 2025 - 20.3K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Ordering.java
list.subList(k, list.size()).clear(); } list.trimToSize(); return unmodifiableList(list); } else { TopKSelector<E> selector = TopKSelector.least(k, this); selector.offerAll(iterator); return selector.topK(); } } /** * Returns the {@code k} greatest elements of the given iterable according to this ordering, in
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 39.4K bytes - Click Count (0) -
guava/src/com/google/common/collect/Ordering.java
list.subList(k, list.size()).clear(); } list.trimToSize(); return unmodifiableList(list); } else { TopKSelector<E> selector = TopKSelector.least(k, this); selector.offerAll(iterator); return selector.topK(); } } /** * Returns the {@code k} greatest elements of the given iterable according to this ordering, in
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 39.4K bytes - Click Count (0)