- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for DataService (0.05 sec)
-
fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
import jakarta.annotation.Resource; public class CrawlerTest extends LastaDiTestCase { @Resource private Crawler crawler; @Resource private DataService dataService; @Resource private UrlQueueService urlQueueService; @Resource private FileTransformer fileTransformer; @Resource private CrawlerContainer crawlerContainer; @OverrideRegistered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 12.8K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
import org.codelibs.fess.crawler.util.CrawlerWebServer; import org.dbflute.utflute.core.PlainTestCase; public class CrawlerTest extends PlainTestCase { public Crawler crawler; public DataService dataService; public UrlQueueService urlQueueService; public FileTransformer fileTransformer; private StandardCrawlerContainer container; @Override protected void setUp() throws Exception {Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 19.1K bytes - Viewed (0) -
README.md
crawler.addUrl("https://example.com/sitemap.xml"); ``` ## Data Access and Storage ### Accessing Crawled Data ```java // Get data service DataService dataService = container.getComponent("dataService"); // Iterate through crawled data dataService.iterate(sessionId, accessResult -> { System.out.println("URL: " + accessResult.getUrl()); System.out.println("Status: " + accessResult.getHttpStatusCode());
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Aug 31 05:32:52 UTC 2025 - 15.3K bytes - Viewed (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
} dataService.iterate(sessionId1, accessResult -> assertTrue(accessResult.getUrl().startsWith(url1))); dataService.iterate(sessionId2, accessResult -> assertTrue(accessResult.getUrl().startsWith(url2))); dataService.delete(sessionId1); dataService.delete(sessionId2); } finally { try {Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 7.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
*/ @Resource protected UrlQueueService<UrlQueue<?>> urlQueueService; /** * Service for managing access result data. */ @Resource protected DataService<AccessResult<?>> dataService; /** * Container for managing crawler components. */ @Resource protected CrawlerContainer crawlerContainer; /**Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 20.4K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java
import org.opensearch.search.SearchHits; import jakarta.annotation.PostConstruct; /** * OpenSearchDataService is an implementation of {@link DataService} for OpenSearch. */ public class OpenSearchDataService extends AbstractCrawlerService implements DataService<OpenSearchAccessResult> { /** * Creates a new instance of OpenSearchDataService. * @param crawlerConfig The crawler configuration. */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
private static final Logger logger = LogManager.getLogger(OpenSearchUrlQueueService.class); /** * Data service for checking access results. */ @Resource protected OpenSearchDataService dataService; /** * Cache for session queues. */ protected Map<String, QueueHolder> sessionCache = new ConcurrentHashMap<>(); /** * The number of URLs to fetch when polling. */
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 17K bytes - Viewed (1) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/entity/OpenSearchAccessResult.java
*/ @Override public AccessResultData<String> getAccessResultData() { if (!initializedData) { final OpenSearchDataService dataService = SingletonLaContainer.getComponent(OpenSearchDataService.class); final OpenSearchAccessResult accessResult = dataService.getAccessResult(getSessionId(), getUrl()); if (accessResult != null && accessResult.accessResultData != null) {Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 6.5K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java
*/ @Resource protected UrlQueueService<UrlQueue<?>> urlQueueService; /** * Service for managing access result data. */ @Resource protected DataService<AccessResult<?>> dataService; /** * Filter for URLs to control which URLs are crawled. */ @Resource protected UrlFilter urlFilter; /** * Manager for crawling rules and configurations.Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 14K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/DataServiceImpl.java
import org.codelibs.fess.crawler.helper.MemoryDataHelper; import org.codelibs.fess.crawler.service.DataService; import org.codelibs.fess.crawler.util.AccessResultCallback; import jakarta.annotation.Resource; /** * Implementation of the {@link DataService} interface for managing access result data. * This class provides methods to store, retrieve, update, and delete access results,Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 6.8K bytes - Viewed (0)