Package org.elasticsearch.search.query

Class QuerySearchResult

java.lang.Object

org.elasticsearch.transport.TransportMessage

org.elasticsearch.transport.TransportResponse

org.elasticsearch.search.SearchPhaseResult

org.elasticsearch.search.query.QuerySearchResult

All Implemented Interfaces:

Writeable

public final class QuerySearchResult
extends SearchPhaseResult

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.transport.TransportResponse

TransportResponse.Empty

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Field Summary

Fields inherited from class org.elasticsearch.search.SearchPhaseResult

requestId

Constructor Summary

Constructors

Constructor	Description
QuerySearchResult()
QuerySearchResult(long id, SearchShardTarget shardTarget)
QuerySearchResult(StreamInput in)

Method Summary

Modifier and Type	Method	Description
void	aggregations(InternalAggregations aggregations)
Aggregations	consumeAggs()	Returns and nulls out the aggregation for this search results.
ProfileShardResult	consumeProfileResult()	Returns and nulls out the profiled results for this search, or potentially null if result was empty.
TopDocsAndMaxScore	consumeTopDocs()	Returns and nulls out the top docs for this search results.
int	from()
QuerySearchResult	from(int from)
float	getMaxScore()
org.apache.lucene.search.TotalHits	getTotalHits()
boolean	hasAggs()	Returns true if this query result has unconsumed aggregations
boolean	hasConsumedTopDocs()	Returns true iff the top docs have already been consumed.
boolean	hasProfileResults()
boolean	hasSearchContext()
boolean	hasSuggestHits()	Returns true if this result has any suggest score docs
int	nodeQueueSize()
QuerySearchResult	nodeQueueSize(int nodeQueueSize)
void	profileResults(ProfileShardResult shardResults)	Sets the finalized profiling results for this query
QuerySearchResult	queryResult()	Returns the query result iff it's included in this response otherwise null
void	readFromWithId(long id, StreamInput in)
boolean	searchTimedOut()
void	searchTimedOut(boolean searchTimedOut)
long	serviceTimeEWMA()
QuerySearchResult	serviceTimeEWMA(long serviceTimeEWMA)
int	size()	Returns the maximum size of this results top docs.
QuerySearchResult	size(int size)
DocValueFormat[]	sortValueFormats()
Suggest	suggest()
void	suggest(Suggest suggest)
java.lang.Boolean	terminatedEarly()
void	terminatedEarly(boolean terminatedEarly)
TopDocsAndMaxScore	topDocs()
void	topDocs(TopDocsAndMaxScore topDocs, DocValueFormat[] sortValueFormats)
void	writeTo(StreamOutput out)	Write this into the StreamOutput.
void	writeToNoId(StreamOutput out)

Methods inherited from class org.elasticsearch.search.SearchPhaseResult

fetchResult, getRequestId, getSearchShardTarget, getShardIndex, setSearchShardTarget, setShardIndex

Methods inherited from class org.elasticsearch.transport.TransportMessage

remoteAddress, remoteAddress

Methods inherited from class java.lang.Object

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

Constructor Detail

QuerySearchResult

public QuerySearchResult()

QuerySearchResult

public QuerySearchResult(StreamInput in)
                  throws java.io.IOException

Throws:

java.io.IOException

QuerySearchResult

public QuerySearchResult(long id,
                         SearchShardTarget shardTarget)

Method Detail

queryResult

public QuerySearchResult queryResult()

Description copied from class: SearchPhaseResult

Returns the query result iff it's included in this response otherwise null

Overrides:

queryResult in class SearchPhaseResult

searchTimedOut

public void searchTimedOut(boolean searchTimedOut)

searchTimedOut

public boolean searchTimedOut()

terminatedEarly

public void terminatedEarly(boolean terminatedEarly)

terminatedEarly

public java.lang.Boolean terminatedEarly()

topDocs

public TopDocsAndMaxScore topDocs()

hasConsumedTopDocs

public boolean hasConsumedTopDocs()

Returns true iff the top docs have already been consumed.

consumeTopDocs

public TopDocsAndMaxScore consumeTopDocs()

Returns and nulls out the top docs for this search results. This allows to free up memory once the top docs are consumed.

Throws:

java.lang.IllegalStateException - if the top docs have already been consumed.

topDocs

public void topDocs(TopDocsAndMaxScore topDocs,
                    DocValueFormat[] sortValueFormats)

sortValueFormats

public DocValueFormat[] sortValueFormats()

hasAggs

public boolean hasAggs()

Returns true if this query result has unconsumed aggregations

consumeAggs

public Aggregations consumeAggs()

Returns and nulls out the aggregation for this search results. This allows to free up memory once the aggregation is consumed.

Throws:

java.lang.IllegalStateException - if the aggregations have already been consumed.

aggregations

public void aggregations(InternalAggregations aggregations)

consumeProfileResult

public ProfileShardResult consumeProfileResult()

Returns and nulls out the profiled results for this search, or potentially null if result was empty. This allows to free up memory once the profiled result is consumed.

Throws:

java.lang.IllegalStateException - if the profiled result has already been consumed.

hasProfileResults

public boolean hasProfileResults()

profileResults

public void profileResults(ProfileShardResult shardResults)

Sets the finalized profiling results for this query

Parameters:

shardResults - The finalized profile

suggest

public Suggest suggest()

suggest

public void suggest(Suggest suggest)

from

public int from()

from

public QuerySearchResult from(int from)

size

public int size()

Returns the maximum size of this results top docs.

size

public QuerySearchResult size(int size)

serviceTimeEWMA

public long serviceTimeEWMA()

serviceTimeEWMA

public QuerySearchResult serviceTimeEWMA(long serviceTimeEWMA)

nodeQueueSize

public int nodeQueueSize()

nodeQueueSize

public QuerySearchResult nodeQueueSize(int nodeQueueSize)

hasSuggestHits

public boolean hasSuggestHits()

Returns true if this result has any suggest score docs

hasSearchContext

public boolean hasSearchContext()

readFromWithId

public void readFromWithId(long id,
                           StreamInput in)
                    throws java.io.IOException

Throws:

java.io.IOException

writeTo

public void writeTo(StreamOutput out)
             throws java.io.IOException

Description copied from interface: Writeable

Write this into the StreamOutput.

Specified by:

writeTo in interface Writeable

Overrides:

writeTo in class SearchPhaseResult

Throws:

java.io.IOException

writeToNoId

public void writeToNoId(StreamOutput out)
                 throws java.io.IOException

Throws:

java.io.IOException

getTotalHits

public org.apache.lucene.search.TotalHits getTotalHits()

getMaxScore

public float getMaxScore()