Package org.codelibs.fess.indexer

Class IndexUpdater

java.lang.Object

java.lang.Thread

org.codelibs.fess.indexer.IndexUpdater

All Implemented Interfaces:

Runnable

public class IndexUpdater
extends Thread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected ClickLogBhv	clickLogBhv
protected org.codelibs.fess.crawler.service.DataService<org.codelibs.fess.crawler.entity.EsAccessResult>	dataService
protected long	documentSize
protected long	executeTime
protected FavoriteLogBhv	favoriteLogBhv
protected boolean	finishCrawling
protected List<String>	finishedSessionIdList
protected IndexingHelper	indexingHelper
protected int	maxErrorCount
protected int	maxIndexerErrorCount
protected SearchEngineClient	searchEngineClient
protected List<String>	sessionIdList
protected SystemHelper	systemHelper
protected org.codelibs.fess.crawler.service.UrlFilterService	urlFilterService
protected org.codelibs.fess.crawler.service.UrlQueueService<org.codelibs.fess.crawler.entity.EsUrlQueue>	urlQueueService

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
IndexUpdater()

Method Summary

Modifier and Type	Method	Description
protected void	addBoostValue(Map<String,Object> map, float documentBoost)
protected void	addClickCountField(Map<String,Object> doc)
void	addDocBoostMatcher(DocBoostMatcher rule)
protected void	addFavoriteCountField(Map<String,Object> map)
void	addFinishedSessionId(String sessionId)
void	destroy()
long	getDocumentSize()
long	getExecuteTime()
List<String>	getSessionIdList()
protected Map<String,Object>	ingest(org.codelibs.fess.crawler.entity.AccessResult<String> accessResult, Map<String,Object> map)
void	init()
void	run()
void	setCrawlerList(List<org.codelibs.fess.crawler.Crawler> crawlerList)
static void	setDefaultUncaughtExceptionHandler(Thread.UncaughtExceptionHandler eh)
void	setFinishCrawling(boolean finishCrawling)
void	setMaxIndexerErrorCount(int maxIndexerErrorCount)
void	setSessionIdList(List<String> sessionIdList)
void	setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler eh)
protected void	updateDocument(Map<String,Object> map)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

sessionIdList

protected List<String> sessionIdList

searchEngineClient

protected SearchEngineClient searchEngineClient

dataService

protected org.codelibs.fess.crawler.service.DataService<org.codelibs.fess.crawler.entity.EsAccessResult> dataService

urlQueueService

protected org.codelibs.fess.crawler.service.UrlQueueService<org.codelibs.fess.crawler.entity.EsUrlQueue> urlQueueService

urlFilterService

protected org.codelibs.fess.crawler.service.UrlFilterService urlFilterService

clickLogBhv

protected ClickLogBhv clickLogBhv

favoriteLogBhv

protected FavoriteLogBhv favoriteLogBhv

systemHelper

protected SystemHelper systemHelper

indexingHelper

protected IndexingHelper indexingHelper

finishCrawling

protected boolean finishCrawling

executeTime

protected long executeTime

documentSize

protected long documentSize

maxIndexerErrorCount

protected int maxIndexerErrorCount

maxErrorCount

protected int maxErrorCount

finishedSessionIdList

protected List<String> finishedSessionIdList

Constructor Detail

IndexUpdater

public IndexUpdater()

Method Detail

init

@PostConstruct
public void init()

destroy

@PreDestroy
public void destroy()

addFinishedSessionId

public void addFinishedSessionId(String sessionId)

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

ingest

protected Map<String,Object> ingest(org.codelibs.fess.crawler.entity.AccessResult<String> accessResult,
                                          Map<String,Object> map)

updateDocument

protected void updateDocument(Map<String,Object> map)

addBoostValue

protected void addBoostValue(Map<String,Object> map,
                             float documentBoost)

addClickCountField

protected void addClickCountField(Map<String,Object> doc)

addFavoriteCountField

protected void addFavoriteCountField(Map<String,Object> map)

getExecuteTime

public long getExecuteTime()

getSessionIdList

public List<String> getSessionIdList()

setSessionIdList

public void setSessionIdList(List<String> sessionIdList)

setFinishCrawling

public void setFinishCrawling(boolean finishCrawling)

getDocumentSize

public long getDocumentSize()

setUncaughtExceptionHandler

public void setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler eh)

Overrides:

setUncaughtExceptionHandler in class Thread

setDefaultUncaughtExceptionHandler

public static void setDefaultUncaughtExceptionHandler(Thread.UncaughtExceptionHandler eh)

setMaxIndexerErrorCount

public void setMaxIndexerErrorCount(int maxIndexerErrorCount)

addDocBoostMatcher

public void addDocBoostMatcher(DocBoostMatcher rule)

setCrawlerList

public void setCrawlerList(List<org.codelibs.fess.crawler.Crawler> crawlerList)