Package org.elasticsearch.action.search

Class SearchExecutionStatsCollector

java.lang.Object

org.elasticsearch.action.search.SearchExecutionStatsCollector

All Implemented Interfaces:

ActionListener<SearchPhaseResult>

public final class SearchExecutionStatsCollector
extends java.lang.Object
implements ActionListener<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.MappedActionListener<Response,MappedResponse>

Method Summary

Modifier and Type	Method	Description
static java.util.function.BiFunction<Transport.Connection,org.elasticsearch.action.search.SearchActionListener,ActionListener>	makeWrapper(ResponseCollectorService service)
void	onFailure(java.lang.Exception e)	A failure caused by an exception at some phase of the task.
void	onResponse(SearchPhaseResult response)	Handle action response.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.action.ActionListener

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.

Specified by:

onResponse in interface ActionListener<SearchPhaseResult>

onFailure

public void onFailure(java.lang.Exception e)

Description copied from interface: ActionListener

A failure caused by an exception at some phase of the task.

Specified by:

onFailure in interface ActionListener<SearchPhaseResult>