public class ReindexSolrBusyThread extends AbstractBusyThread
Modifier and Type | Field and Description |
---|---|
(package private) int |
chunksize |
(package private) CollectionConfiguration |
colcfg |
(package private) java.lang.String |
currentquery |
(package private) int |
docstoreindex |
(package private) SolrConnector |
esc |
(package private) int |
processed |
(package private) OrderedScoreMap<java.lang.String> |
querylist |
(package private) java.util.concurrent.Semaphore |
sem |
(package private) int |
start |
static java.lang.String |
THREAD_NAME |
busytime, memuse, running
Constructor and Description |
---|
ReindexSolrBusyThread(java.lang.String query) |
Modifier and Type | Method and Description |
---|---|
void |
addSelectFieldname(java.lang.String field)
add a fieldname to select documents to reindex all documents
containing the given fieldname are reindexed
|
void |
addSelectQuery(java.lang.String query)
add a query selecting documents to reindex
|
void |
freemem()
is called when an outOfMemoryCycle is performed
this method should try to free some memory, so that the job can be executed
|
java.lang.String |
getCurrentQuery() |
int |
getJobCount() |
int |
getProcessed() |
OrderedScoreMap<java.lang.String> |
getQueryList() |
boolean |
job()
each call reindexes a chunk of 100 documents until all selected documents are reindexed
|
void |
terminate(boolean waitFor) |
getBusyCycles, getBusySleep, getHighCPUCycles, getIdleCycles, getIdleSleep, getOutOfMemoryCycles, getSleepTime, intermission, notifyThread, run, setBusySleep, setIdleSleep, setLoadPreReqisite, setMemPreReqisite, setObeyIntermission, setStartupSleep
announceThreadBlockApply, announceThreadBlockRelease, close, getBlockTime, getExecTime, getLongDescription, getMemoryUse, getMonitorURL, getShortDescription, jobExceptionHandler, open, setDescription, shutdownInProgress
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
close, getBlockTime, getExecTime, getLongDescription, getMemoryUse, getMonitorURL, getShortDescription, isAlive, jobExceptionHandler, open, setDescription, shutdownInProgress, start
public static final java.lang.String THREAD_NAME
SolrConnector esc
final CollectionConfiguration colcfg
int processed
int docstoreindex
java.util.concurrent.Semaphore sem
OrderedScoreMap<java.lang.String> querylist
java.lang.String currentquery
int start
int chunksize
public ReindexSolrBusyThread(java.lang.String query)
query
- = a solr query to select documents to reindex (like h5_txt:[* TO *])public void addSelectQuery(java.lang.String query)
public void addSelectFieldname(java.lang.String field)
field
- a solr fieldnamepublic boolean job()
public void terminate(boolean waitFor)
terminate
in interface WorkflowThread
terminate
in class AbstractThread
public int getProcessed()
public java.lang.String getCurrentQuery()
public OrderedScoreMap<java.lang.String> getQueryList()
public int getJobCount()
public void freemem()
BusyThread