public class UnrankedSearchStreamExecutor extends UnrankedSearchExecutor
Modifier and Type | Field and Description |
---|---|
protected com.exalead.search.outputs.StreamableAnswerFormatter |
af |
protected com.exalead.search.SearchContainer |
container |
protected com.exalead.io.FastBufferedOutputStream |
output |
protected com.exalead.search.StreamSearchResult |
result |
answerAllocationContext, antiGC, categoryProcessors, dlogger, fullHitsPipe, limitBehav, limitError, logger, queryContext, scgdata, searchContext, sliceDownBehav, sliceDownError, synthesisContainer, target, tickMessageAllocatorContext, timeoutBehav, timeoutError
Constructor and Description |
---|
UnrankedSearchStreamExecutor() |
Modifier and Type | Method and Description |
---|---|
protected com.exalead.search.BaseSearchResult |
getSearchResult() |
protected boolean |
onFullHitReceived(com.exalead.search.fullhits.FullHitMessage hit) |
void |
search(com.exalead.search.SearchContainer container) |
buildQueryPerContentGroup, computeMaxFetchedHits, onCategoryGroupReceived, onDeinit, onEndOfQueryReceived, onInit, onSearchErrorReceived, prepareForQuery
protected com.exalead.search.SearchContainer container
protected com.exalead.search.StreamSearchResult result
protected com.exalead.io.FastBufferedOutputStream output
protected com.exalead.search.outputs.StreamableAnswerFormatter af
public void search(com.exalead.search.SearchContainer container) throws QueryProcessingException, com.exalead.search.SearchProcessingException
QueryProcessingException
com.exalead.search.SearchProcessingException
protected com.exalead.search.BaseSearchResult getSearchResult()
getSearchResult
in class UnrankedSearchExecutor
protected boolean onFullHitReceived(com.exalead.search.fullhits.FullHitMessage hit)
onFullHitReceived
in class UnrankedSearchExecutor
Copyright © 2013 Dassault Systèmes, All Rights Reserved.