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.

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 interface org.elasticsearch.action.ActionListener

onFailure, onResponse, toBiConsumer, wrap, wrap

Methods inherited from class java.lang.Object

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

Method Detail

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>