com.exalead.search.runner

Class ExpandExecutor

java.lang.Object

com.exalead.search.runner.ExpandExecutor

All Implemented Interfaces:

com.exalead.search.SearchLogicRunner

public class ExpandExecutor
extends java.lang.Object
implements com.exalead.search.SearchLogicRunner

Field Summary

Fields

Modifier and Type	Field and Description
protected com.exalead.search.outputs.ExpandStreamFormatter	af
protected com.exalead.search.internal.answer.AnswerAllocationContext	answerAllocationContext
java.util.List<com.exalead.search.index6.CategorySynthesisProcessor>	categoryProcessors
protected static org.apache.log4j.Logger	dlogger
protected FullHitsPipelineHelper	fullHitsPipe
protected static org.apache.log4j.Logger	logger
protected int	nbPath
protected com.exalead.io.FastBufferedOutputStream	output
protected StandardQueryContext	queryContext
protected com.exalead.search.ExpandResult	result
protected com.exalead.search.index6.SliceAndCGData	scgdata
protected com.exalead.search.index6.expand.ExpandContext	searchContext
protected SynthesisContainer	synthesisContainer
protected SearchTarget	target
protected com.exalead.tick2.TickMessageAllocator	tickMessageAllocatorContext

Constructor Summary

Constructors

Constructor and Description
ExpandExecutor()

Method Summary

Modifier and Type	Method and Description
protected void	buildQueryPerContentGroup() Build the internal tick messages, and configure everything so that all content groups work on them.
protected boolean	onCategoryGroupReceived(int id, com.exalead.search.index6.CategorySynthesisMessage message)
void	onDeinit()
protected boolean	onEndOfQueryReceived(long nProcessedHits, long nMatches, boolean estimated, long indexCPUTime, byte[] slicesInfo)
void	onInit()
protected boolean	onPathReceived(com.exalead.search.index6.expand.PathMessage path)
protected boolean	onSearchErrorReceived(java.lang.String errorMessage)
protected boolean	prepareForQuery()
void	search(com.exalead.search.SearchContainer container)

Methods inherited from class java.lang.Object

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

Field Detail

target

protected SearchTarget target

queryContext

protected StandardQueryContext queryContext

scgdata

protected com.exalead.search.index6.SliceAndCGData scgdata

result

protected com.exalead.search.ExpandResult result

output

protected com.exalead.io.FastBufferedOutputStream output

nbPath

protected int nbPath

af

protected com.exalead.search.outputs.ExpandStreamFormatter af

fullHitsPipe

protected final FullHitsPipelineHelper fullHitsPipe

searchContext

protected final com.exalead.search.index6.expand.ExpandContext searchContext

answerAllocationContext

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

tickMessageAllocatorContext

protected final com.exalead.tick2.TickMessageAllocator tickMessageAllocatorContext

synthesisContainer

protected final SynthesisContainer synthesisContainer

categoryProcessors

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

logger

protected static org.apache.log4j.Logger logger

dlogger

protected static org.apache.log4j.Logger dlogger

Constructor Detail

ExpandExecutor

public ExpandExecutor()

Method Detail

onInit

public void onInit()

Specified by:

onInit in interface com.exalead.search.SearchLogicRunner

onDeinit

public void onDeinit()

Specified by:

onDeinit in interface com.exalead.search.SearchLogicRunner

buildQueryPerContentGroup

protected void buildQueryPerContentGroup()
                                  throws QueryProcessingException

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

Throws:

QueryProcessingException

prepareForQuery

protected boolean prepareForQuery()
                           throws QueryProcessingException

Throws:

QueryProcessingException

onPathReceived

protected boolean onPathReceived(com.exalead.search.index6.expand.PathMessage path)
                          throws com.exalead.search.SearchProcessingException

Throws:

com.exalead.search.SearchProcessingException

onSearchErrorReceived

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

Throws:

com.exalead.search.SearchProcessingException

onEndOfQueryReceived

protected boolean onEndOfQueryReceived(long nProcessedHits,
                                       long nMatches,
                                       boolean estimated,
                                       long indexCPUTime,
                                       byte[] slicesInfo)

onCategoryGroupReceived

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

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