- Sort Score
- Num 10 results
- Language All
Results 231 - 240 of 295 for Transport (0.06 seconds)
-
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) -
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) -
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; } @OverrideCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 12.2K bytes - Click Count (0) -
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 documentsCreated: 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/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) -
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) -
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) -
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) -
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; @BeforeClassCreated: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Mon Sep 01 13:33:03 GMT 2025 - 14.4K bytes - Click Count (0) -
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)