- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 49 for actionGet (0.84 seconds)
-
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() .getTotalHits()
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Wed Jan 14 23:48:16 GMT 2026 - 14.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java
final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout); if (bulkResponse.hasFailures()) { throw new IllegalBehaviorStateException(bulkResponse.buildFailureMessage()); } response = client.prepareSearchScroll(scrollId).setScroll(scrollForDelete).execute().actionGet(scrollSearchTimeout);
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 27 07:01:25 GMT 2025 - 26.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
client.admin().indices().prepareGetIndex().addIndices(updateAlias).execute().actionGet(fessConfig.getIndexIndicesTimeout()); final String[] updateIndices = response1.indices(); final GetIndexResponse response2 = client.admin().indices().prepareGetIndex().addIndices(searchAlias).execute().actionGet(fessConfig.getIndexIndicesTimeout()); final String[] searchIndices = response2.indices();
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 14:36:23 GMT 2026 - 138.6K bytes - Click Count (1) -
src/test/java/org/codelibs/fess/suggest/util/ScrollOperationHelperTest.java
runner.close(); runner.clean(); } @Before public void before() throws Exception { runner.admin().indices().prepareDelete("_all").execute().actionGet(); runner.refresh(); suggester = Suggester.builder().build(client, "ScrollTest"); suggester.createIndexIfNothing(); } @Test public void testScrollSearch_emptyResults() {
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Feb 01 12:48:24 GMT 2026 - 7K bytes - Click Count (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());Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Mon Nov 24 03:40:05 GMT 2025 - 11.1K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.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 public void test_Read() throws Exception {
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Nov 23 13:04:17 GMT 2025 - 8.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java
.setQuery(queryBuilder) .setSize(500) .setScroll(settings.getScrollTimeout()) .execute() .actionGet(settings.getSearchTimeout()); String scrollId = response.getScrollId(); try { while (scrollId != null) { final SearchHit[] hits = response.getHits().getHits();
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Nov 23 11:21:40 GMT 2025 - 17.5K bytes - Click Count (1) -
src/test/java/org/codelibs/fess/suggest/SuggesterIndexLifecycleTest.java
assertTrue("Should have at least 2 indices before cleanup", beforeRemove.getIndices().length >= 2); // Remove orphaned indices suggester.removeDisableIndices(); // After cleanup GetIndexResponse afterRemove = runner.admin().indices().prepareGetIndex().addIndices(getIndexName() + "*").execute().actionGet();
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sat Mar 14 02:35:38 GMT 2026 - 13.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/index/operations/DeletionOperations.java
.setSize(SCROLL_PAGE_SIZE) .setScroll(settings.getScrollTimeout()) .setQuery(QueryBuilders.rangeQuery(freqField).gte(1)) .execute() .actionGet(settings.getSearchTimeout()); String scrollId = response.getScrollId(); try { while (scrollId != null) { final SearchHit[] hits = response.getHits().getHits();
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Feb 01 12:48:24 GMT 2026 - 9.5K bytes - Click Count (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()) {
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Thu Nov 20 08:32:33 GMT 2025 - 4.5K bytes - Click Count (0)