public class SearchTransportService extends AbstractLifecycleComponent
SearchService
operations exposed through
transport.Modifier and Type | Class and Description |
---|---|
static class |
SearchTransportService.SearchFreeContextResponse |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CLEAR_SCROLL_CONTEXTS_ACTION_NAME |
static java.lang.String |
DFS_ACTION_NAME |
static java.lang.String |
FETCH_ID_ACTION_NAME |
static java.lang.String |
FETCH_ID_SCROLL_ACTION_NAME |
static java.lang.String |
FREE_CONTEXT_ACTION_NAME |
static java.lang.String |
FREE_CONTEXT_SCROLL_ACTION_NAME |
static java.lang.String |
QUERY_ACTION_NAME |
static java.lang.String |
QUERY_FETCH_ACTION_NAME
Deprecated.
|
static java.lang.String |
QUERY_FETCH_SCROLL_ACTION_NAME |
static java.lang.String |
QUERY_ID_ACTION_NAME |
static java.lang.String |
QUERY_SCROLL_ACTION_NAME |
lifecycle
deprecationLogger, logger, settings
Constructor and Description |
---|
SearchTransportService(Settings settings,
ClusterSettings clusterSettings,
TransportService transportService) |
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
logDeprecatedSetting, logRemovedSetting, nodeName
public static final java.lang.String FREE_CONTEXT_SCROLL_ACTION_NAME
public static final java.lang.String FREE_CONTEXT_ACTION_NAME
public static final java.lang.String CLEAR_SCROLL_CONTEXTS_ACTION_NAME
public static final java.lang.String DFS_ACTION_NAME
public static final java.lang.String QUERY_ACTION_NAME
public static final java.lang.String QUERY_ID_ACTION_NAME
public static final java.lang.String QUERY_SCROLL_ACTION_NAME
@Deprecated public static final java.lang.String QUERY_FETCH_ACTION_NAME
public static final java.lang.String QUERY_FETCH_SCROLL_ACTION_NAME
public static final java.lang.String FETCH_ID_SCROLL_ACTION_NAME
public static final java.lang.String FETCH_ID_ACTION_NAME
public SearchTransportService(Settings settings, ClusterSettings clusterSettings, TransportService transportService)
public void sendFreeContext(Transport.Connection connection, long contextId, OriginalIndices originalIndices)
public void sendFreeContext(DiscoveryNode node, long contextId, ActionListener<SearchTransportService.SearchFreeContextResponse> listener)
public void sendClearAllScrollContexts(DiscoveryNode node, ActionListener<TransportResponse> listener)
public void sendExecuteDfs(Transport.Connection connection, ShardSearchTransportRequest request, SearchTask task, org.elasticsearch.action.search.SearchActionListener<DfsSearchResult> listener)
public void sendExecuteQuery(Transport.Connection connection, ShardSearchTransportRequest request, SearchTask task, org.elasticsearch.action.search.SearchActionListener<SearchPhaseResult> listener)
public void sendExecuteQuery(Transport.Connection connection, QuerySearchRequest request, SearchTask task, org.elasticsearch.action.search.SearchActionListener<QuerySearchResult> listener)
public void sendExecuteScrollQuery(DiscoveryNode node, InternalScrollSearchRequest request, SearchTask task, org.elasticsearch.action.search.SearchActionListener<ScrollQuerySearchResult> listener)
public void sendExecuteScrollFetch(DiscoveryNode node, InternalScrollSearchRequest request, SearchTask task, org.elasticsearch.action.search.SearchActionListener<ScrollQueryFetchSearchResult> listener)
public void sendExecuteFetch(Transport.Connection connection, ShardFetchSearchRequest request, SearchTask task, org.elasticsearch.action.search.SearchActionListener<FetchSearchResult> listener)
public void sendExecuteFetchScroll(DiscoveryNode node, ShardFetchRequest request, SearchTask task, org.elasticsearch.action.search.SearchActionListener<FetchSearchResult> listener)
public RemoteClusterService getRemoteClusterService()
public static void registerRequestHandler(TransportService transportService, SearchService searchService)
protected void doStart()
doStart
in class AbstractLifecycleComponent
protected void doStop()
doStop
in class AbstractLifecycleComponent
protected void doClose() throws java.io.IOException
doClose
in class AbstractLifecycleComponent
java.io.IOException