Logo Search packages:      
Sourcecode: uimaj version File versions  Download package

Public Member Functions | Public Attributes | Protected Member Functions | Protected Attributes | Private Member Functions | Private Attributes | Static Private Attributes

org::apache::uima::collection::impl::cpm::engine::ProcessingUnit Class Reference

Collaboration diagram for org::apache::uima::collection::impl::cpm::engine::ProcessingUnit:
Collaboration graph
[legend]

List of all members.

Public Member Functions

void addStatusCallbackListener (BaseStatusCallbackListener aListener)
void cleanup ()
boolean consumeQueue ()
void disableCasProcessor (String aCasProcessorName)
void disableCasProcessor (int aCasProcessorIndex)
void enableCasProcessor (String aCasProcessorName)
ArrayList getCallbackListeners ()
boolean isCasConsumerPipeline ()
boolean isRunning ()
 ProcessingUnit (CPMEngine acpm, BoundedWorkQueue aInputQueue, BoundedWorkQueue aOutputQueue)
 ProcessingUnit (CPMEngine acpm)
void removeStatusCallbackListener (BaseStatusCallbackListener aListener)
void run ()
void setCasConsumerPipelineIdentity ()
void setCasPool (CPECasPool aPool)
void setContainers (LinkedList processorList)
void setCPMEngine (CPMEngine acpm)
void setInputQueue (BoundedWorkQueue aInputQueue)
void setNotifyListeners (boolean aDoNotify)
void setOutputQueue (BoundedWorkQueue aOutputQueue)
void setProcessingUnitProcessTrace (ProcessTrace aProcessingUnitProcessTrace)
void setReleaseCASFlag (boolean aFlag)
void setUimaTimer (UimaTimer aTimer)
void stopCasProcessors (boolean kill)

Public Attributes

int threadState = 0
long timer01 = 0
long timer02 = 0
long timer03 = 0
long timer04 = 0
long timer05 = 0
long timer06 = 0

Protected Member Functions

boolean analyze (Object[] aCasObjectList, ProcessTrace pTrTemp) throws Exception
void doNotifyListeners (Object aCas, boolean isCasObject, EntityProcessStatus aEntityProcStatus)
boolean endOfProcessingReached (long aCount)
long getBytes (Object aCas)
boolean isProcessorReady (int aStatus)
void notifyListeners (Object aCas, boolean isCasObject, EntityProcessStatus aEntityProcStatus)
void process (Object anArtifact)
boolean processNext (Object[] aCasObjectList, ProcessTrace pTrTemp) throws ResourceProcessException, IOException, CollectionException, AbortCPMException, KillPipelineException
void showMetadata (Object[] aCasList)

Protected Attributes

Object[] artifact = null
CAS[] casList
CPECasPool casPool
CAS conversionCas = null
CAS[] conversionCasArray
CpeConfiguration cpeConfiguration = null
CPMEngine cpm = null
CasConverter mConverter
boolean notifyListeners = false
long numToProcess = 0
BoundedWorkQueue outputQueue = null
LinkedList processContainers = new LinkedList()
ProcessTrace processingUnitProcessTrace
boolean releaseCAS = false
ArrayList statusCbL = new ArrayList()
String threadId = null
UimaTimer timer
BoundedWorkQueue workQueue = null

Private Member Functions

void clearCasCache ()
boolean containerDisabled (ProcessingContainer aContainer)
void convertCasDataToCasObject (int casIndex, String aContainerName, Object[] aCasObjectList) throws Exception
void doEndOfBatch (ProcessingContainer aContainer, CasProcessor aProcessor, ProcessTrace aProcessTr, int howManyCases)
void doEndOfBatchProcessing (ProcessingContainer aContainer, CasProcessor aProcessor, ProcessTrace aProcessTr, Object[] aCasObjectList)
void doReleaseCasProcessor (ProcessingContainer aContainer, CasProcessor aCasProcessor)
boolean filterOutTheCAS (ProcessingContainer aContainer, boolean isCasObject, Object[] aCasObjectList)
ProcessTrace getProcessTrace ()
void handleAbortCasProcessor (ProcessingContainer aContainer, CasProcessor aProcessor) throws Exception
void handleAbortCPM (ProcessingContainer aContainer, CasProcessor aProcessor) throws Exception
void handleEOFToken () throws Exception
boolean handleErrors (Throwable e, ProcessingContainer aContainer, CasProcessor aProcessor, ProcessTrace aProcessTrace, Object[] aCasObjectList, boolean isCasObject) throws Exception
void handleKillPipeline (ProcessingContainer aContainer) throws Exception
void handleServiceException (ProcessingContainer aContainer, CasProcessor aProcessor, ProcessTrace aProcessTr, Exception ex) throws Exception
void handleSkipCasProcessor (ProcessingContainer aContainer, Object[] aCasObjectList, boolean isLastCP) throws Exception
void invokeCasDataCasProcessor (ProcessingContainer container, CasProcessor processor, Object[] aCasObjectList, ProcessTrace pTrTemp, boolean isCasObject, boolean retry) throws Exception
void invokeCasObjectCasProcessor (ProcessingContainer container, CasProcessor processor, Object[] aCasObjectList, ProcessTrace pTrTemp, boolean isCasObject) throws Exception
void isCpmPaused ()
void logCPM (Level level, String msgBundleId, Object[] args)
void logFinest (String msgBundleId, ProcessingContainer container, CasProcessor processor)
void logFinest (String msgBundleId)
void logFinest (String msgBundleId, String arg1)
void logFinest (String msgBundleId, String arg1, String arg2)
void logFinest (String msgBundleId, String arg1, String arg2, String arg3)
void logMemoryFinest ()
void logSevere (String msgBundleId, String arg1, String arg2)
void logSevere (String msgBundleId, String arg1)
void logSevere (String msgBundleId, String arg1, String arg2, String arg3)
void logWarning (String msgBundleId)
void logWarning (String msgBundleId, String arg1, String arg2)
void maybeLogFinest (String msgBundleId, ProcessingContainer container, CasProcessor processor, CAS[] casCache)
void maybeLogFinest (String msgBundleId, ProcessingContainer container)
void maybeLogFinest (String msgBundleId, CasProcessor processor)
void maybeLogFinest (String msgBundleId, CAS[] casCache)
void maybeLogFinest (String msgBundleId, ProcessingContainer container, CasProcessor processor)
void maybeLogFinest (String msgBundleId)
void maybeLogFinest (String msgBundleId, String arg1)
void maybeLogFinest (String msgBundleId, String arg1, String arg2)
void maybeLogFinestWorkQueue (String msgBundleId, BoundedWorkQueue workQueue)
void maybeLogMemoryFinest ()
void maybeLogSevere (String msgBundleId, String arg1)
void maybeLogSevere (String msgBundleId)
void maybeLogSevere (String msgBundleId, String arg1, String arg2)
void maybeLogSevere (String msgBundleId, String arg1, String arg2, String arg3)
void maybeLogSevereException (Throwable e)
void maybeLogWarning (String msgBundleId, String arg1, String arg2)
boolean pauseContainer (ProcessingContainer aContainer, Exception aException, String aThreadId)
void postAnalysis (Object[] aCasObjectList, boolean isCasObject, Object[] casObjects, ProcessTrace aProcessTr, boolean doneAlready) throws Exception
void releaseCases (Object aCasList, boolean lastProcessor, String aName)
void releaseTimedOutCases (Object[] artifact)

Private Attributes

CAS[] casCache = null
boolean isCasConsumerPipeline = false
boolean isRunning = false

Static Private Attributes

static final String thisClassName = ProcessingUnit.class.getName()
static final Object[] zeroLengthObjectArray = new Object[0]

Detailed Description

This component executes the processing pipeline. Running in a seperate thread it continuously reads bundles of Cas from the Work Queue filled by ArtifactProducer and sends it through configured CasProcessors. The sequence in which CasProcessors are invoked is defined by the order of Cas Processor listing in the cpe descriptor. The results of analysis produced be Cas Processors is enqueued onto an output queue that is shared with Cas Consumers.

Definition at line 73 of file ProcessingUnit.java.


The documentation for this class was generated from the following file:

Generated by  Doxygen 1.6.0   Back to index