Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 33 for actionGet (0.11 sec)

  1. src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java

                        if (bulkResponse.hasFailures()) {
                            throw new SuggesterException(bulkResponse.buildFailureMessage());
                        }
                        response = client.prepareSearchScroll(scrollId).setScroll(settings.getScrollTimeout()).execute()
                                .actionGet(settings.getSearchTimeout());
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  2. 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());
                        if (!scrollId.equals(response.getScrollId())) {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

            SearchResponse response = client.prepareSearch(index).setSize(500).setScroll(settings.getScrollTimeout())
                    .setQuery(QueryBuilders.rangeQuery(FieldNames.DOC_FREQ).gte(1)).execute().actionGet(settings.getSearchTimeout());
            String scrollId = response.getScrollId();
            try {
                while (scrollId != null) {
                    final SearchHit[] hits = response.getHits().getHits();
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/suggest/converter/AnalyzerConverter.java

                final AnalyzeAction.Response termResponse =
                        client.admin().indices().prepareAnalyze(analyzerSettings.getAnalyzerSettingsIndexName(), text)
                                .setAnalyzer(analyzerSettings.getReadingTermAnalyzerName(field, lang)).execute()
                                .actionGet(settings.getIndicesTimeout());
    
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java

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

                    bulkRequestBuilder.add(indexRequestBuilder);
                }
            }
    
            final BulkResponse response = bulkRequestBuilder.execute().actionGet(settings.getBulkTimeout());
            final SuggestWriterResult result = new SuggestWriterResult();
            if (response.hasFailures()) {
                for (final BulkItemResponse bulkItemResponses : response.getItems()) {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/score/ScoreBooster.java

                    .setFetchSource(false).setSize(fessConfig.getPageScoreBoosterMaxFetchSizeAsInteger()).execute().actionGet(requestTimeout);
            return Arrays.stream(response.getHits().getHits()).map(SearchHit::getId).toArray(n -> new String[n]);
        };
    
        protected Function<Map<String, Object>, Long> requestHandler = params -> {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/suggest/normalizer/AnalyzerNormalizer.java

                        .prepareAnalyze(analyzerSettings.getAnalyzerSettingsIndexName(), text)
                        .setAnalyzer(analyzerSettings.getNormalizeAnalyzerName(field, lang)).execute().actionGet(settings.getIndicesTimeout());
    
                final List<AnalyzeToken> termTokenList = termResponse.getTokens();
                if (termTokenList.isEmpty()) {
                    return text;
                }
    
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/timer/HotThreadMonitorTarget.java

                        esClient.admin().cluster().prepareNodesHotThreads().setIgnoreIdleThreads(ignoreIdleThreads).setInterval(interval)
                                .setThreads(threads).setTimeout(timeout).setType(type).execute().actionGet(timeout);
                append(buf, "cluster_name", () -> response.getClusterName().value()).append(',');
                final String hotThreads = response.getNodesMap().entrySet().stream().map(e -> {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  10. test-site/app/models/ContentsCreator.java

                        .setType(ComponentsUtil.contentTypeName)
                        .setCreate(true)
                        .setSource(source)
                        .execute()
                        .actionGet();
                    count++;
                    Thread.sleep(500);
                } catch(Exception e) {
                    Logger.warn(e.getMessage(), e);
                }
            }
        }
    
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Fri Nov 06 08:48:32 UTC 2015
    - 3.7K bytes
    - Viewed (0)
Back to top