Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 12 for DataService (0.07 seconds)

  1. src/test/java/org/codelibs/fess/indexer/IndexUpdaterTest.java

        }
    
        // Test run method with null DataService
        @Test
        public void test_run_nullDataService() {
            indexUpdater.dataService = null;
            try {
                indexUpdater.run();
                fail("Should throw FessSystemException");
            } catch (FessSystemException e) {
                assertEquals("DataService is null. IndexUpdater cannot proceed without a DataService instance.", e.getMessage());
            }
        }
    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)
  2. 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.
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Mon Nov 24 03:59:47 GMT 2025
    - 17K bytes
    - Click Count (0)
  3. 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;
    
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Jan 15 01:11:43 GMT 2026
    - 13.1K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

         * if too many empty results are encountered or if a system shutdown is requested.
         */
        @Override
        public void run() {
            if (dataService == null) {
                throw new FessSystemException("DataService is null. IndexUpdater cannot proceed without a DataService instance.");
            }
    
            if (logger.isDebugEnabled()) {
                logger.debug("Starting indexUpdater.");
            }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 32.9K bytes
    - Click Count (0)
  5. 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;
    
        /**
    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)
  6. 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());
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Sun Aug 31 05:32:52 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  7. 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> {
    
        /**
         * Fields to fetch for access result list without data.
         */
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Mon Nov 24 03:59:47 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  8. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataServiceTest.java

            dataService.delete("id1");
    
            assertNull(dataService.getAccessResult("id1", "http://www.id1.com/"));
            assertNotNull(dataService.getAccessResult("id2", "http://www.id2.com/"));
    
            dataService.store(accessResult1);
            assertNotNull(dataService.getAccessResult("id1", "http://www.id1.com/"));
    
            dataService.deleteAll();
    
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Jan 14 23:48:16 GMT 2026
    - 15.7K bytes
    - Click Count (0)
  9. 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.
         */
    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)
  10. src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java

            final OpenSearchUrlQueueService urlQueueService = ComponentUtil.getComponent(OpenSearchUrlQueueService.class);
            final OpenSearchDataService dataService = ComponentUtil.getComponent(OpenSearchDataService.class);
    
            try {
                // clear url filter
                urlFilterService.delete(sid);
            } catch (final Exception e) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 25K bytes
    - Click Count (0)
Back to Top