- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 33 for actionGet (0.11 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
test-site/app/models/ContentsCreator.java
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Fri Nov 06 08:48:32 UTC 2015 - 3.7K bytes - Viewed (0)