public class ArtifactProducer extends Thread
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
int |
threadState |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
ArtifactProducer(CPMEngine acpm)
Instantiates and initializes this instance.
|
ArtifactProducer(CPMEngine acpm,
CPECasPool aPool)
Construct instance of this class with a reference to the cpe engine and a pool of cas'es.
|
Modifier and Type | Method and Description |
---|---|
void |
cleanup()
Null out fields of this object.
|
void |
fillQueue()
Fills the queue up to capacity.
|
long |
getCollectionReaderTotalFetchTime()
Returns total time spent when fetching entities from a CollectionReader.
|
String |
getLastDocId() |
void |
invalidate(CAS[] aCasList) |
boolean |
isRunning() |
void |
run()
Runs this thread until the CPM halts or the CollectionReader has no more entities.
|
void |
setCollectionReader(BaseCollectionReader aCollectionReader)
Assign CollectionReader to be used for reading
|
void |
setCPMStatTable(Map aStatTable)
Add table that will contain statistics gathered while reading entities from a Collection This
table is used for non-uima reports.
|
void |
setNumEntitiesToProcess(long aNumToProcess)
Assign total number of entities to process
|
void |
setProcessTrace(ProcessTrace aProcTrace) |
void |
setUimaTimer(UimaTimer aTimer)
Plug in Custom Timer to time events
|
void |
setWorkQueue(BoundedWorkQueue aQueue)
Assigns a queue where the artifacts produced by this component will be deposited
|
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
public ArtifactProducer(CPMEngine acpm)
acpm
- public ArtifactProducer(CPMEngine acpm, CPECasPool aPool)
acpm
- -
reference to the cpeaPool
- -
pool of casespublic boolean isRunning()
public void setUimaTimer(UimaTimer aTimer)
aTimer
- -
custom timerpublic void setProcessTrace(ProcessTrace aProcTrace)
public long getCollectionReaderTotalFetchTime()
public void cleanup()
public void setNumEntitiesToProcess(long aNumToProcess)
aNumToProcess
- -
number of entities to read from the Collection Readerpublic void setCollectionReader(BaseCollectionReader aCollectionReader)
aCollectionReader
- -
collection reader as source of datapublic void setWorkQueue(BoundedWorkQueue aQueue)
aQueue
- -
queue for the artifacts this class is producingpublic void setCPMStatTable(Map aStatTable)
aStatTable
- public void fillQueue() throws Exception
Exception
public void run()
public String getLastDocId()
public void invalidate(CAS[] aCasList)
Copyright © 2006–2024 The Apache Software Foundation. All rights reserved.