Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 33 for actionGet (0.07 sec)

  1. src/test/java/org/codelibs/fess/suggest/settings/ArraySettingsTest.java

            runner.close();
            runner.clean();
        }
    
        @Before
        public void before() throws Exception {
            try {
                runner.admin().indices().prepareDelete("_all").execute().actionGet();
            } catch (IndexNotFoundException ignore) {
    
            }
            runner.refresh();
            settings = Suggester.builder().build(runner.client(), id).settings();
        }
    
        @Test
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/IndexingHelper.java

            final SearchResponse countResponse = searchEngineClient.prepareSearch(fessConfig.getIndexDocumentUpdateIndex())
                    .setQuery(queryBuilder).setSize(0).setTrackTotalHits(true).execute().actionGet(fessConfig.getIndexSearchTimeout());
            final TotalHits totalHits = countResponse.getHits().getTotalHits();
            if (totalHits != null) {
                return totalHits.value;
            }
            return 0;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/suggest/SuggesterTest.java

            runner.close();
            runner.clean();
        }
    
        @Before
        public void before() throws Exception {
            runner.admin().indices().prepareDelete("_all").execute().actionGet();
            runner.refresh();
            suggester = Suggester.builder().build(runner.client(), "SuggesterTest");
            suggester.createIndexIfNothing();
        }
    
        @Test
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 37K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/suggest/settings/BadWordSettingsTest.java

            runner.close();
            runner.clean();
        }
    
        @Before
        public void before() throws Exception {
            try {
                runner.admin().indices().prepareDelete("_all").execute().actionGet();
            } catch (IndexNotFoundException ignore) {
    
            }
            runner.refresh();
            settings = Suggester.builder().build(runner.client(), id).settings();
        }
    
        @Test
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/suggest/settings/SuggestSettingsTest.java

            runner.close();
            runner.clean();
        }
    
        @Before
        public void before() throws Exception {
            try {
                runner.admin().indices().prepareDelete("_all").execute().actionGet();
            } catch (IndexNotFoundException ignore) {
    
            }
            runner.refresh();
            settings = Suggester.builder().build(runner.client(), id).settings();
        }
    
        @Test
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/suggest/settings/ElevateWordSettingsTest.java

            runner.close();
            runner.clean();
        }
    
        @Before
        public void before() throws Exception {
            try {
                runner.admin().indices().prepareDelete("_all").execute().actionGet();
            } catch (IndexNotFoundException ignore) {
    
            }
            runner.refresh();
            settings = Suggester.builder().build(runner.client(), id).settings();
        }
    
        @Test
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/suggest/settings/AnalyzerSettingsTest.java

            runner.close();
            runner.clean();
        }
    
        @Before
        public void before() throws Exception {
            try {
                runner.admin().indices().prepareDelete("_all").execute().actionGet();
            } catch (IndexNotFoundException ignore) {
    
            }
            runner.refresh();
            settings = Suggester.builder().build(runner.client(), id).settings();
        }
    
        @Test
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.java

            try {
                final SearchEngineClient esClient = ComponentUtil.getSearchEngineClient();
                final NodesStatsResponse response = esClient.admin().cluster().prepareNodesStats().all().execute().actionGet(10000L);
                final XContentBuilder builder = XContentFactory.jsonBuilder();
                builder.startObject();
                response.toXContent(builder, ToXContent.EMPTY_PARAMS);
                builder.endObject();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  9. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

        }
    
        public <T> T get(final Function<FesenClient, ActionFuture<T>> func) {
            int retryCount = 0;
            while (true) {
                try {
                    return func.apply(this).actionGet(connTimeout, TimeUnit.MILLISECONDS);
                } catch (final IndexNotFoundException | VersionConflictEngineException e) {
                    logger.debug("{} occurs.", e.getClass().getName(), e);
                    throw e;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/helper/SuggestHelper.java

            final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient();
            searchEngineClient.admin().cluster().prepareHealth().setWaitForYellowStatus().execute()
                    .actionGet(fessConfig.getIndexHealthTimeout());
    
            final SuggestSettingsBuilder settingsBuilder = SuggestSettings.builder();
            settingsBuilder.addInitialSettings("search_engine.type", fessConfig.getFesenType());
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 18.1K bytes
    - Viewed (0)
Back to top