Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 49 for actionGet (0.84 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top