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

  • Field Details

    • 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 Details

    • IndexUpdater

      public IndexUpdater()

  • Method Details

    • 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)