protected class HttpPoster.IngestThread extends Thread
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
protected Map<String,String[]> |
aclsMap |
protected Long |
activityBytes |
protected String |
activityCode |
protected String |
activityDetails |
protected Long |
activityStart |
protected Map<String,List<String>> |
arguments |
protected Map<String,String[]> |
denyAclsMap |
protected RepositoryDocument |
document |
protected String |
documentURI |
protected Throwable |
exception |
protected boolean |
keepAllMetadata |
protected boolean |
readFromDocumentStreamYet |
protected boolean |
rval |
protected Map<String,List<String>> |
sourceTargets |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
HttpPoster.IngestThread(String documentURI,
RepositoryDocument document,
Map<String,List<String>> arguments,
boolean keepAllMetadata,
Map<String,List<String>> sourceTargets,
Map<String,String[]> aclsMap,
Map<String,String[]> denyAclsMap) |
Modifier and Type | Method and Description |
---|---|
void |
finishUp() |
Long |
getActivityBytes() |
String |
getActivityCode() |
String |
getActivityDetails() |
Long |
getActivityStart() |
boolean |
getReadFromDocumentStreamYet() |
boolean |
getRval() |
void |
run() |
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 documentURI
protected final RepositoryDocument document
protected final boolean keepAllMetadata
protected Long activityStart
protected Long activityBytes
protected String activityCode
protected String activityDetails
protected Throwable exception
protected boolean readFromDocumentStreamYet
protected boolean rval
public void finishUp() throws InterruptedException, org.apache.solr.client.solrj.SolrServerException, IOException
InterruptedException
org.apache.solr.client.solrj.SolrServerException
IOException
public Long getActivityStart()
public Long getActivityBytes()
public String getActivityCode()
public String getActivityDetails()
public boolean getReadFromDocumentStreamYet()
public boolean getRval()