Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
protected Set<String> |
addFails |
protected Set<String> |
deleteFails |
protected List<String> |
deletes |
protected boolean |
doDeletes |
protected String |
id |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
StoppableIndexingThread(SolrClient controlClient,
SolrClient cloudClient,
String id,
boolean doDeletes) |
StoppableIndexingThread(SolrClient controlClient,
SolrClient cloudClient,
String id,
boolean doDeletes,
int numCycles,
int batchSize,
boolean pauseBetweenUpdates) |
Modifier and Type | Method and Description |
---|---|
protected void |
addFields(SolrInputDocument doc,
Object... fields) |
Set<String> |
getAddFails() |
Set<String> |
getDeleteFails() |
int |
getFailCount() |
int |
getNumAdds() |
int |
getNumDeletes() |
protected void |
indexDocs(List<SolrInputDocument> docs) |
void |
run() |
void |
safeStop() |
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
protected final String id
protected boolean doDeletes
public StoppableIndexingThread(SolrClient controlClient, SolrClient cloudClient, String id, boolean doDeletes)
public StoppableIndexingThread(SolrClient controlClient, SolrClient cloudClient, String id, boolean doDeletes, int numCycles, int batchSize, boolean pauseBetweenUpdates)
public void safeStop()
public int getFailCount()
protected void addFields(SolrInputDocument doc, Object... fields)
protected void indexDocs(List<SolrInputDocument> docs) throws IOException, SolrServerException
IOException
SolrServerException
public int getNumDeletes()
public int getNumAdds()
Copyright © 2000–2015 The Apache Software Foundation. All rights reserved.