Package org.elasticsearch.action.search

Class QueryPhaseResultConsumer

java.lang.Object

org.elasticsearch.action.search.QueryPhaseResultConsumer

All Implemented Interfaces:

Closeable, AutoCloseable, org.elasticsearch.core.Releasable

public class QueryPhaseResultConsumer
extends Object
implements org.elasticsearch.core.Releasable

A ArraySearchPhaseResults implementation that incrementally reduces aggregation results as shard results are consumed. This implementation adds the memory that it used to save and reduce the results of shard aggregations in the CircuitBreaker.REQUEST circuit breaker. Before any partial or final reduce, the memory needed to reduce the aggregations is estimated and a CircuitBreakingException is thrown if it exceeds the maximum memory allowed in this breaker.

Constructor Summary

Constructors

Constructor	Description
QueryPhaseResultConsumer(SearchRequest request, Executor executor, CircuitBreaker circuitBreaker, SearchPhaseController controller, SearchProgressListener progressListener, NamedWriteableRegistry namedWriteableRegistry, int expectedResultSize, Consumer<Exception> onPartialMergeFailure)	Creates a QueryPhaseResultConsumer that incrementally reduces aggregation results as shard results are consumed.

Method Summary

Modifier and Type	Method	Description
void	close()
void	consumeResult(SearchPhaseResult result, Runnable next)
int	getNumReducePhases()
SearchPhaseController.ReducedQueryPhase	reduce()

Methods inherited from class java.lang.Object

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

Constructor Details

QueryPhaseResultConsumer

public QueryPhaseResultConsumer(SearchRequest request,
 Executor executor,
 CircuitBreaker circuitBreaker,
 SearchPhaseController controller,
 SearchProgressListener progressListener,
 NamedWriteableRegistry namedWriteableRegistry,
 int expectedResultSize,
 Consumer<Exception> onPartialMergeFailure)

Creates a QueryPhaseResultConsumer that incrementally reduces aggregation results as shard results are consumed.

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.elasticsearch.core.Releasable

consumeResult

public void consumeResult(SearchPhaseResult result,
 Runnable next)

reduce

public SearchPhaseController.ReducedQueryPhase reduce()
                                               throws Exception

Throws:

Exception

getNumReducePhases

public int getNumReducePhases()