Package org.elasticsearch.action.search

Class SearchExecutionStatsCollector

java.lang.Object

org.elasticsearch.action.ActionListener.Delegating<SearchPhaseResult,SearchPhaseResult>

org.elasticsearch.action.search.SearchExecutionStatsCollector

All Implemented Interfaces:

ActionListener<SearchPhaseResult>

public final class SearchExecutionStatsCollector
extends ActionListener.Delegating<SearchPhaseResult,SearchPhaseResult>

A wrapper of search action listeners (search results) that unwraps the query result to get the piggybacked queue size and service time EWMA, adding those values to the coordinating nodes' ResponseCollectorService.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.action.ActionListener

ActionListener.Delegating<Response,DelegateResponse>, ActionListener.DelegatingActionListener<T>, ActionListener.DelegatingFailureActionListener<T,R>, ActionListener.MappedActionListener<Response,MappedResponse>, ActionListener.RunAfterActionListener<T>, ActionListener.RunBeforeActionListener<T>

Field Summary

Fields inherited from class org.elasticsearch.action.ActionListener.Delegating

delegate

Method Summary

Modifier and Type	Method	Description
static java.util.function.BiFunction<Transport.Connection,org.elasticsearch.action.search.SearchActionListener,ActionListener>	makeWrapper(ResponseCollectorService service)
void	onResponse(SearchPhaseResult response)	Handle action response.

Methods inherited from class org.elasticsearch.action.ActionListener.Delegating

onFailure, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.elasticsearch.action.ActionListener

delegateFailure, delegateResponse, map

Method Details

makeWrapper

public static java.util.function.BiFunction<Transport.Connection,org.elasticsearch.action.search.SearchActionListener,ActionListener> makeWrapper(ResponseCollectorService service)

onResponse

public void onResponse(SearchPhaseResult response)

Description copied from interface: ActionListener

Handle action response. This response may constitute a failure or a success but it is up to the listener to make that decision.