com.exalead.search.runner

Class RankedSearchExecutor<T extends com.exalead.search.index6.common.SortableSearchContext<?>>

java.lang.Object

com.exalead.search.runner.RankedSearchExecutor<T>

All Implemented Interfaces:

com.exalead.search.SearchLogicRunner

Direct Known Subclasses:

RankedHeapSearchExecutor, RankedLocalSortSearchExecutor

public abstract class RankedSearchExecutor<T extends com.exalead.search.index6.common.SortableSearchContext<?>>
extends java.lang.Object
implements com.exalead.search.SearchLogicRunner

Execute a ranked search, return a cacheable result.

Field Summary

Fields

Modifier and Type	Field and Description
protected com.exalead.search.internal.answer.AnswerAllocationContext	answerAllocationContext
protected QueryProcessingContext	antiGC
java.util.List<com.exalead.search.index6.CategorySynthesisProcessor>	categoryProcessors
protected com.exalead.search.SearchContainer	currentContainer
protected boolean	fullHitsOver
FullHitsPipelineHelper	fullHitsPipe
LogBehaviour	limitBehav
boolean	limitError
protected static org.apache.log4j.Logger	logger
protected StandardQueryContext	queryContext
protected com.exalead.search.index6.SliceAndCGData	scgdata
protected T	searchContext
LogBehaviour	sliceDownBehav
boolean	sliceDownError
protected com.exalead.mercury.util.LoggerWithStopWatch	slogger
protected boolean	stopped
protected SynthesisContainer	synthesisContainer
protected boolean	synthesisOver
protected com.exalead.tick2.TickMessageAllocator	tickMessageAllocatorContext
LogBehaviour	timeoutBehav
boolean	timeoutError

Constructor Summary

Constructors

Constructor and Description
RankedSearchExecutor()

Method Summary

Modifier and Type	Method and Description
protected abstract void	buildTickMessagesForAllContentGroups() Build the internal tick messages, and configure everything so that all content groups work on them.
protected abstract java.lang.String	getExecutorName()
protected boolean	isOver()
protected boolean	onCategoryGroupReceived(int id, com.exalead.search.index6.CategorySynthesisMessage message)
void	onDeinit()
protected boolean	onEndOfSynthesisReceived(long indexCPUTime)
protected boolean	onFullHitReceived(com.exalead.search.fullhits.FullHitMessage hit, long indexCPUTime)
void	onInit()
protected boolean	onSearchErrorReceived(java.lang.String errorMessage)
protected boolean	requestFullHitsIfNeeded(long selectorSize)
void	search(com.exalead.search.SearchContainer container)
protected boolean	setFullHitsOver() Notify end of full hits.
protected boolean	setSynthesisOver() Notify end of synthesis

Methods inherited from class java.lang.Object

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

Field Detail

categoryProcessors

public final java.util.List<com.exalead.search.index6.CategorySynthesisProcessor> categoryProcessors

fullHitsPipe

public final FullHitsPipelineHelper fullHitsPipe

answerAllocationContext

protected final com.exalead.search.internal.answer.AnswerAllocationContext answerAllocationContext

tickMessageAllocatorContext

protected final com.exalead.tick2.TickMessageAllocator tickMessageAllocatorContext

searchContext

protected T extends com.exalead.search.index6.common.SortableSearchContext<?> searchContext

synthesisContainer

protected final SynthesisContainer synthesisContainer

currentContainer

protected com.exalead.search.SearchContainer currentContainer

queryContext

protected StandardQueryContext queryContext

scgdata

protected com.exalead.search.index6.SliceAndCGData scgdata

antiGC

protected QueryProcessingContext antiGC

fullHitsOver

protected boolean fullHitsOver

synthesisOver

protected boolean synthesisOver

stopped

protected boolean stopped

logger

protected static org.apache.log4j.Logger logger

sliceDownError

public boolean sliceDownError

sliceDownBehav

public LogBehaviour sliceDownBehav

timeoutError

public boolean timeoutError

timeoutBehav

public LogBehaviour timeoutBehav

limitError

public boolean limitError

limitBehav

public LogBehaviour limitBehav

slogger

protected com.exalead.mercury.util.LoggerWithStopWatch slogger

Constructor Detail

RankedSearchExecutor

public RankedSearchExecutor()

Method Detail

onInit

public void onInit()
            throws java.lang.Exception

Specified by:

onInit in interface com.exalead.search.SearchLogicRunner

Throws:

java.lang.Exception

onDeinit

public void onDeinit()

Specified by:

onDeinit in interface com.exalead.search.SearchLogicRunner

search

public void search(com.exalead.search.SearchContainer container)
            throws QueryProcessingException,
                   com.exalead.search.SearchProcessingException

Specified by:

search in interface com.exalead.search.SearchLogicRunner

Throws:

QueryProcessingException

com.exalead.search.SearchProcessingException

buildTickMessagesForAllContentGroups

protected abstract void buildTickMessagesForAllContentGroups()
                                                      throws QueryProcessingException

Build the internal tick messages, and configure everything so that all content groups work on them.

Throws:

QueryProcessingException

setFullHitsOver

protected boolean setFullHitsOver()

Notify end of full hits.

isOver

protected boolean isOver()

setSynthesisOver

protected boolean setSynthesisOver()

Notify end of synthesis

Returns:

true if you should exist (both FH and Syn done)

onCategoryGroupReceived

protected boolean onCategoryGroupReceived(int id,
                                          com.exalead.search.index6.CategorySynthesisMessage message)

onSearchErrorReceived

protected boolean onSearchErrorReceived(java.lang.String errorMessage)
                                 throws com.exalead.search.SearchProcessingException

Throws:

com.exalead.search.SearchProcessingException

requestFullHitsIfNeeded

protected boolean requestFullHitsIfNeeded(long selectorSize)
                                   throws com.exalead.util.TypedException

Throws:

com.exalead.util.TypedException

onEndOfSynthesisReceived

protected boolean onEndOfSynthesisReceived(long indexCPUTime)

onFullHitReceived

protected boolean onFullHitReceived(com.exalead.search.fullhits.FullHitMessage hit,
                                    long indexCPUTime)

getExecutorName

protected abstract java.lang.String getExecutorName()