Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 53 for Execute (0.02 sec)

  1. README.md

    Crawler crawler2 = container.getComponent("crawler");  
    crawler2.setSessionId("session2");
    crawler2.addUrl("https://site2.com");
    
    // Execute concurrently
    crawler1.setBackground(true);
    crawler2.setBackground(true);
    
    String sessionId1 = crawler1.execute();
    String sessionId2 = crawler2.execute();
    
    crawler1.awaitTermination();
    crawler2.awaitTermination();
    ```
    
    ### Custom Interval Control
    
    ```java
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Aug 31 05:32:52 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  2. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                crawler2.getCrawlerContext().setMaxAccessCount(maxCount);
                crawler2.getCrawlerContext().setNumOfThread(numOfThread);
    
                final String sessionId1 = crawler1.execute();
                final String sessionId2 = crawler2.execute();
    
                assertNotSame(sessionId1, sessionId2);
                assertNotSame(crawler1.crawlerContext, crawler2.crawlerContext);
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java

                        }
                        response = builder.execute().actionGet(settings.getSearchTimeout());
                    } else {
                        response = client.prepareSearchScroll(scrollId)
                                .setScroll(settings.getScrollTimeout())
                                .execute()
                                .actionGet(settings.getSearchTimeout());
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 11K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/suggest/SuggesterTest.java

            assertEquals(1, response.getNum());
            assertEquals("全文 検索", response.getWords().get(0));
    
            response = suggester.suggest().addKind("query").execute().getResponse();
            assertEquals(1, response.getNum());
    
            SuggestResponse response2 = suggester.suggest().setSuggestDetail(true).execute().getResponse();
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 37.2K bytes
    - Viewed (0)
  5. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

                        return bulkBuilder.execute();
                    });
                    if (bulkResponse.hasFailures()) {
                        throw new OpenSearchAccessException(bulkResponse.buildFailureMessage());
                    }
    
                    final String sid = scrollId;
                    response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute());
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 34.2K bytes
    - Viewed (0)
  6. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java

                    .execute()
                    .actionGet()
                    .getHits()
                    .getTotalHits()
                    .value() > 0);
            assertTrue(fesenClient.prepareSearch("fess_crawler.queue")
                    .setQuery(QueryBuilders.termQuery("sessionId", "id2"))
                    .execute()
                    .actionGet()
                    .getHits()
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/suggest/Suggester.java

                            .addAlias(new Alias(getUpdateAlias(index)))
                            .execute()
                            .actionGet(suggestSettings.getIndicesTimeout());
    
                    client.admin().cluster().prepareHealth().setWaitForYellowStatus().execute().actionGet(suggestSettings.getClusterTimeout());
                    created = true;
                }
                return created;
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 20.7K bytes
    - Viewed (3)
  8. src/main/java/org/codelibs/fess/suggest/settings/AnalyzerSettings.java

                    .setSettings(settings)
                    .execute()
                    .actionGet(this.settings.getIndicesTimeout());
        }
    
        /**
         * Deletes the analyzer settings.
         */
        protected void deleteAnalyzerSettings() {
            client.admin().indices().prepareDelete(analyzerSettingsIndexName).execute().actionGet(settings.getIndicesTimeout());
        }
    
        /**
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/suggest/request/RequestBuilder.java

            this.client = client;
            this.request = request;
        }
    
        /**
         * Executes the request.
         * @return A Promise that will be resolved with the response or rejected with an error.
         */
        public Deferred<Res>.Promise execute() {
            return request.execute(client);
        }
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Fri Jul 04 14:00:23 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java

                SearchResponse response = client.prepareSearch(index)
                        .setQuery(queryBuilder)
                        .setSize(500)
                        .setScroll(settings.getScrollTimeout())
                        .execute()
                        .actionGet(settings.getSearchTimeout());
                String scrollId = response.getScrollId();
                try {
                    while (scrollId != null) {
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Mon Sep 01 13:33:03 UTC 2025
    - 17.4K bytes
    - Viewed (1)
Back to top