Package org.codelibs.fess.ds.callback

Class FileListIndexUpdateCallbackImpl

java.lang.Object

org.codelibs.fess.ds.callback.FileListIndexUpdateCallbackImpl

All Implemented Interfaces:

IndexUpdateCallback

public class FileListIndexUpdateCallbackImpl
extends java.lang.Object
implements IndexUpdateCallback

Field Summary

Fields

Modifier and Type	Field	Description
protected org.codelibs.fess.crawler.client.CrawlerClientFactory	crawlerClientFactory
protected java.util.List<java.lang.String>	deleteUrlList
protected IndexUpdateCallback	indexUpdateCallback
protected int	maxDeleteDocumentCacheSize
protected int	maxRedirectCount

Constructor Summary

Constructors

Constructor	Description
FileListIndexUpdateCallbackImpl(IndexUpdateCallback indexUpdateCallback, org.codelibs.fess.crawler.client.CrawlerClientFactory crawlerClientFactory, int nThreads)

Method Summary

Modifier and Type	Method	Description
protected void	addDocument(java.util.Map<java.lang.String,java.lang.String> paramMap, java.util.Map<java.lang.String,java.lang.Object> dataMap)
void	commit()
protected boolean	deleteDocument(java.util.Map<java.lang.String,java.lang.String> paramMap, java.util.Map<java.lang.String,java.lang.Object> dataMap)
protected void	deleteDocuments()
long	getDocumentSize()
long	getExecuteTime()
protected java.lang.String	getParamValue(java.util.Map<java.lang.String,java.lang.String> paramMap, java.lang.String key, java.lang.String defaultValue)
protected java.util.concurrent.ExecutorService	newFixedThreadPool(int nThreads)
protected java.lang.String	processRequest(java.util.Map<java.lang.String,java.lang.String> paramMap, java.util.Map<java.lang.String,java.lang.Object> dataMap, java.lang.String url, org.codelibs.fess.crawler.client.CrawlerClient client)
void	setExecutorTerminationTimeout(int executorTerminationTimeout)
void	setMaxDeleteDocumentCacheSize(int maxDeleteDocumentCacheSize)
void	setMaxRedirectCount(int maxRedirectCount)
void	store(java.util.Map<java.lang.String,java.lang.String> paramMap, java.util.Map<java.lang.String,java.lang.Object> dataMap)

Methods inherited from class java.lang.Object

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

Field Detail

indexUpdateCallback

protected IndexUpdateCallback indexUpdateCallback

crawlerClientFactory

protected org.codelibs.fess.crawler.client.CrawlerClientFactory crawlerClientFactory

deleteUrlList

protected java.util.List<java.lang.String> deleteUrlList

maxDeleteDocumentCacheSize

protected int maxDeleteDocumentCacheSize

maxRedirectCount

protected int maxRedirectCount

Constructor Detail

FileListIndexUpdateCallbackImpl

public FileListIndexUpdateCallbackImpl(IndexUpdateCallback indexUpdateCallback,
                                       org.codelibs.fess.crawler.client.CrawlerClientFactory crawlerClientFactory,
                                       int nThreads)

Method Detail

newFixedThreadPool

protected java.util.concurrent.ExecutorService newFixedThreadPool(int nThreads)

store

public void store(java.util.Map<java.lang.String,java.lang.String> paramMap,
                  java.util.Map<java.lang.String,java.lang.Object> dataMap)

Specified by:

store in interface IndexUpdateCallback

getParamValue

protected java.lang.String getParamValue(java.util.Map<java.lang.String,java.lang.String> paramMap,
                                         java.lang.String key,
                                         java.lang.String defaultValue)

addDocument

protected void addDocument(java.util.Map<java.lang.String,java.lang.String> paramMap,
                           java.util.Map<java.lang.String,java.lang.Object> dataMap)

processRequest

protected java.lang.String processRequest(java.util.Map<java.lang.String,java.lang.String> paramMap,
                                          java.util.Map<java.lang.String,java.lang.Object> dataMap,
                                          java.lang.String url,
                                          org.codelibs.fess.crawler.client.CrawlerClient client)

deleteDocument

protected boolean deleteDocument(java.util.Map<java.lang.String,java.lang.String> paramMap,
                                 java.util.Map<java.lang.String,java.lang.Object> dataMap)

commit

public void commit()

Specified by:

commit in interface IndexUpdateCallback

deleteDocuments

protected void deleteDocuments()

getDocumentSize

public long getDocumentSize()

Specified by:

getDocumentSize in interface IndexUpdateCallback

getExecuteTime

public long getExecuteTime()

Specified by:

getExecuteTime in interface IndexUpdateCallback

setMaxDeleteDocumentCacheSize

public void setMaxDeleteDocumentCacheSize(int maxDeleteDocumentCacheSize)

setMaxRedirectCount

public void setMaxRedirectCount(int maxRedirectCount)

setExecutorTerminationTimeout

public void setExecutorTerminationTimeout(int executorTerminationTimeout)