Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 231 - 240 of 295 for Transport (0.15 seconds)

  1. src/main/java/org/codelibs/fess/suggest/request/popularwords/PopularWordsRequest.java

    import org.opensearch.index.query.functionscore.ScoreFunctionBuilders;
    import org.opensearch.search.SearchHit;
    import org.opensearch.search.rescore.QueryRescorerBuilder;
    import org.opensearch.transport.client.Client;
    
    /**
     * Represents a request for popular words. This class extends {@link Request} and is parameterized
     * with {@link PopularWordsResponse}. It allows specifying various criteria for retrieving popular words,
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Thu Aug 07 02:41:28 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

    import org.opensearch.index.query.QueryBuilder;
    import org.opensearch.search.Scroll;
    import org.opensearch.search.SearchHit;
    import org.opensearch.threadpool.ThreadPool;
    import org.opensearch.transport.client.AdminClient;
    import org.opensearch.transport.client.Client;
    
    import jakarta.annotation.PreDestroy;
    
    /**
     * FesenClient is a client for OpenSearch.
     *
     * @author shinsuke
     *
     */
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Sun Nov 23 02:01:26 GMT 2025
    - 26.2K bytes
    - Click Count (0)
  3. src/test/java/jcifs/internal/RequestWithPathTest.java

            @Override
            public void setSessionId(long sessionId) {
            }
    
            @Override
            public void reset() {
            }
    
            // Message interface methods (from jcifs.util.transport.Message)
            @Override
            public void retainPayload() {
            }
    
            @Override
            public boolean isRetainPayload() {
                return false;
            }
    
            @Override
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.2K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java

    import org.opensearch.index.query.QueryBuilder;
    import org.opensearch.index.query.QueryBuilders;
    import org.opensearch.search.SearchHit;
    import org.opensearch.search.sort.SortBuilder;
    import org.opensearch.transport.client.Client;
    
    /**
     * <p>
     * {@link ESSourceReader} reads documents from Elasticsearch using the scroll API.
     * It implements the {@link DocumentReader} interface to provide a way to iterate over documents
    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)
  5. src/main/java/org/codelibs/fess/suggest/request/suggest/SuggestRequest.java

    import org.opensearch.index.query.BoolQueryBuilder;
    import org.opensearch.index.query.QueryBuilder;
    import org.opensearch.index.query.QueryBuilders;
    import org.opensearch.search.sort.SortOrder;
    import org.opensearch.transport.client.Client;
    
    /**
     * SuggestRequest is a class that handles the request for suggestions.
     * It extends the Request class with a SuggestResponse type.
     *
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sat Mar 14 02:35:38 GMT 2026
    - 13.5K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/suggest/util/ScrollOperationHelper.java

    import java.util.function.BiConsumer;
    import java.util.function.Consumer;
    
    import org.codelibs.fess.suggest.settings.SuggestSettings;
    import org.opensearch.action.search.SearchResponse;
    import org.opensearch.transport.client.Client;
    import org.opensearch.index.query.QueryBuilder;
    import org.opensearch.search.SearchHit;
    
    /**
     * Helper class for scroll-based search operations in OpenSearch.
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Feb 01 12:48:24 GMT 2026
    - 9.7K bytes
    - Click Count (0)
  7. src/test/java/jcifs/smb/SmbFileInputStreamTest.java

            }
    
            @Test
            @DisplayName("seToIoe maps Interrupted cause to InterruptedIOException")
            void seToIoeInterruptedMapping() {
                SmbException se = new SmbException("x", new jcifs.util.transport.TransportException(new InterruptedException("boom")));
                IOException ioe = SmbFileInputStream.seToIoe(se);
                assertTrue(ioe instanceof InterruptedIOException);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 12.8K bytes
    - Click Count (0)
  8. src/test/java/jcifs/internal/CommonServerMessageBlockRequestTest.java

            // When/Then - Verify the interface extends the expected interfaces
            assertTrue(CommonServerMessageBlock.class.isAssignableFrom(CommonServerMessageBlockRequest.class));
            assertTrue(jcifs.util.transport.Request.class.isAssignableFrom(CommonServerMessageBlockRequest.class));
        }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/fess/suggest/settings/SuggestSettingsBuilderTest.java

    import org.codelibs.opensearch.runner.OpenSearchRunner;
    import org.junit.AfterClass;
    import org.junit.Before;
    import org.junit.BeforeClass;
    import org.junit.Test;
    import org.opensearch.transport.client.Client;
    
    public class SuggestSettingsBuilderTest {
    
        private static OpenSearchRunner runner;
        private static Client client;
        private SuggestSettingsBuilder builder;
    
        @BeforeClass
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Mon Sep 01 13:33:03 GMT 2025
    - 14.4K bytes
    - Click Count (0)
  10. src/test/java/org/codelibs/fess/suggest/SuggesterRefactoringTest.java

    import org.opensearch.action.admin.indices.alias.Alias;
    import org.opensearch.action.admin.indices.alias.get.GetAliasesResponse;
    import org.opensearch.action.admin.indices.create.CreateIndexResponse;
    import org.opensearch.transport.client.Client;
    
    /**
     * Test class for refactoring changes made to Suggester class.
     *
     * Tests cover:
     * - Index alias helper method (getIndicesForAlias)
     * - Edge cases for switchIndex with EXPECTED_INDEX_COUNT
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Feb 01 12:48:24 GMT 2026
    - 13.1K bytes
    - Click Count (0)
Back to Top