org.codelibs.fess.ds.impl

Class FileListIndexUpdateCallbackImpl

java.lang.Object

org.codelibs.fess.ds.impl.FileListIndexUpdateCallbackImpl

All Implemented Interfaces:

IndexUpdateCallback

public class FileListIndexUpdateCallbackImpl
extends Object
implements IndexUpdateCallback

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

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

maxDeleteDocumentCacheSize

protected int maxDeleteDocumentCacheSize

maxRedirectCount

protected int maxRedirectCount

Constructor Detail

FileListIndexUpdateCallbackImpl

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

Method Detail

newFixedThreadPool

protected ExecutorService newFixedThreadPool(int nThreads)

store

public void store(Map<String,String> paramMap,
                  Map<String,Object> dataMap)

Specified by:

store in interface IndexUpdateCallback

getParamValue

protected String getParamValue(Map<String,String> paramMap,
                               String key,
                               String defaultValue)

addDocument

protected void addDocument(Map<String,String> paramMap,
                           Map<String,Object> dataMap)

processRequest

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

deleteDocument

protected boolean deleteDocument(Map<String,String> paramMap,
                                 Map<String,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)