Package org.codelibs.fess.rank.fusion

Class RankFusionProcessor

java.lang.Object

org.codelibs.fess.rank.fusion.RankFusionProcessor

All Implemented Interfaces:

AutoCloseable

public class RankFusionProcessor
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	RankFusionProcessor.SearchRequestParamsWrapper

Field Summary

Fields

Modifier and Type	Field	Description
protected Set<String>	availableSearcherNameSet
protected ExecutorService	executorService
protected RankFusionSearcher[]	searchers
protected int	windowSize

Constructor Summary

Constructors

Constructor	Description
RankFusionProcessor()

Method Summary

Modifier and Type	Method	Description
void	close()
protected QueryResponseList	createResponseList(List<Map<String,Object>> documentList, long allRecordCount, String allRecordCountRelation, long queryTime, boolean partialResults, FacetResponse facetResponse, int start, int pageSize, int offset)
protected List<Map<String,Object>>	extractList(List<Map<String,Object>> docs, int pageSize, int startPosition)
protected RankFusionSearcher[]	getAvailableSearchers()
void	init()
protected void	load()
void	register(RankFusionSearcher searcher)
List<Map<String,Object>>	search(String query, SearchRequestParams params, org.dbflute.optional.OptionalThing<FessUserBean> userBean)
protected List<Map<String,Object>>	searchWithMainSearcher(RankFusionSearcher searcher, String query, SearchRequestParams params, org.dbflute.optional.OptionalThing<FessUserBean> userBean)
protected List<Map<String,Object>>	searchWithMultipleSearchers(RankFusionSearcher[] searchers, String query, SearchRequestParams params, org.dbflute.optional.OptionalThing<FessUserBean> userBean)
void	setSeacher(RankFusionSearcher searcher)
protected float	toFloat(Object value)
void	update()

Methods inherited from class java.lang.Object

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

Field Details

searchers

protected RankFusionSearcher[] searchers

executorService

protected ExecutorService executorService

windowSize

protected int windowSize

availableSearcherNameSet

protected Set<String> availableSearcherNameSet

Constructor Details

RankFusionProcessor

public RankFusionProcessor()

Method Details

init

@PostConstruct
public void init()

update

public void update()

load

protected void load()

close

@PreDestroy
public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

search

public List<Map<String,Object>> search(String query,
 SearchRequestParams params,
 org.dbflute.optional.OptionalThing<FessUserBean> userBean)

getAvailableSearchers

protected RankFusionSearcher[] getAvailableSearchers()

searchWithMultipleSearchers

protected List<Map<String,Object>> searchWithMultipleSearchers(RankFusionSearcher[] searchers,
 String query,
 SearchRequestParams params,
 org.dbflute.optional.OptionalThing<FessUserBean> userBean)

extractList

protected List<Map<String,Object>> extractList(List<Map<String,Object>> docs,
 int pageSize,
 int startPosition)

searchWithMainSearcher

protected List<Map<String,Object>> searchWithMainSearcher(RankFusionSearcher searcher,
 String query,
 SearchRequestParams params,
 org.dbflute.optional.OptionalThing<FessUserBean> userBean)

createResponseList

protected QueryResponseList createResponseList(List<Map<String,Object>> documentList,
 long allRecordCount,
 String allRecordCountRelation,
 long queryTime,
 boolean partialResults,
 FacetResponse facetResponse,
 int start,
 int pageSize,
 int offset)

toFloat

protected float toFloat(Object value)

setSeacher

public void setSeacher(RankFusionSearcher searcher)

register

public void register(RankFusionSearcher searcher)