Class 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 class java.lang.Object

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