Package org.codelibs.fess.ds.callback
Class FileListIndexUpdateCallbackImpl
java.lang.Object
org.codelibs.fess.ds.callback.FileListIndexUpdateCallbackImpl
- All Implemented Interfaces:
IndexUpdateCallback
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected org.codelibs.fess.crawler.client.CrawlerClientFactoryprotected IndexUpdateCallbackprotected intprotected int -
Constructor Summary
ConstructorsConstructorDescriptionFileListIndexUpdateCallbackImpl(IndexUpdateCallback indexUpdateCallback, org.codelibs.fess.crawler.client.CrawlerClientFactory crawlerClientFactory, int nThreads) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidaddDocument(DataStoreParams paramMap, Map<String, Object> dataMap) voidcommit()protected booleandeleteDocument(DataStoreParams paramMap, Map<String, Object> dataMap) protected voidlonglongprotected longgetMaxAccessCount(DataStoreParams paramMap, Map<String, Object> dataMap) protected StringgetParamValue(DataStoreParams paramMap, String key, String defaultValue) protected ExecutorServicenewFixedThreadPool(int nThreads) protected StringprocessRequest(DataStoreParams paramMap, Map<String, Object> dataMap, String url, org.codelibs.fess.crawler.client.CrawlerClient client) voidsetExecutorTerminationTimeout(int executorTerminationTimeout) voidsetMaxDeleteDocumentCacheSize(int maxDeleteDocumentCacheSize) voidsetMaxRedirectCount(int maxRedirectCount) voidstore(DataStoreParams paramMap, Map<String, Object> dataMap)
-
Field Details
-
indexUpdateCallback
-
crawlerClientFactory
protected org.codelibs.fess.crawler.client.CrawlerClientFactory crawlerClientFactory -
deleteUrlList
-
maxDeleteDocumentCacheSize
protected int maxDeleteDocumentCacheSize -
maxRedirectCount
protected int maxRedirectCount
-
-
Constructor Details
-
FileListIndexUpdateCallbackImpl
public FileListIndexUpdateCallbackImpl(IndexUpdateCallback indexUpdateCallback, org.codelibs.fess.crawler.client.CrawlerClientFactory crawlerClientFactory, int nThreads)
-
-
Method Details
-
newFixedThreadPool
-
store
- Specified by:
storein interfaceIndexUpdateCallback
-
getParamValue
-
addDocument
-
getMaxAccessCount
-
processRequest
-
deleteDocument
-
commit
public void commit()- Specified by:
commitin interfaceIndexUpdateCallback
-
deleteDocuments
protected void deleteDocuments() -
getDocumentSize
public long getDocumentSize()- Specified by:
getDocumentSizein interfaceIndexUpdateCallback
-
getExecuteTime
public long getExecuteTime()- Specified by:
getExecuteTimein interfaceIndexUpdateCallback
-
setMaxDeleteDocumentCacheSize
public void setMaxDeleteDocumentCacheSize(int maxDeleteDocumentCacheSize) -
setMaxRedirectCount
public void setMaxRedirectCount(int maxRedirectCount) -
setExecutorTerminationTimeout
public void setExecutorTerminationTimeout(int executorTerminationTimeout)
-