Uses of Class
org.apache.uima.collection.impl.base_cpm.container.ProcessingContainer
-
-
Uses of ProcessingContainer in org.apache.uima.collection.impl.base_cpm.container.deployer
Methods in org.apache.uima.collection.impl.base_cpm.container.deployer that return ProcessingContainer Modifier and Type Method Description ProcessingContainer
CasProcessorDeployer. deployCasProcessor(java.util.List aCasProcessorList, boolean redeploy)
Deploys all Cas Processors in aCasProcessorList.ProcessingContainer
CPEDeployer. deployCasProcessor(ProcessingContainer aProcessingContainer, CasProcessor aCasProcessor, boolean redeploy)
Methods in org.apache.uima.collection.impl.base_cpm.container.deployer with parameters of type ProcessingContainer Modifier and Type Method Description void
CasProcessorDeployer. deployCasProcessor(ProcessingContainer aProcessingContainer)
Method used to redeploy a single instance of a Cas Processor.ProcessingContainer
CPEDeployer. deployCasProcessor(ProcessingContainer aProcessingContainer, CasProcessor aCasProcessor, boolean redeploy)
-
Uses of ProcessingContainer in org.apache.uima.collection.impl.cpm.container
Subclasses of ProcessingContainer in org.apache.uima.collection.impl.cpm.container Modifier and Type Class Description class
ProcessingContainer_Impl
Manages a pool of CasProcessor instances. -
Uses of ProcessingContainer in org.apache.uima.collection.impl.cpm.container.deployer
Methods in org.apache.uima.collection.impl.cpm.container.deployer that return ProcessingContainer Modifier and Type Method Description ProcessingContainer
CPEDeployerDefaultImpl. deployCasProcessor(java.util.List aCasProcessorList, boolean redeploy)
Deploys integrated Cas Processor.ProcessingContainer
CPEDeployerDefaultImpl. deployCasProcessor(java.util.List aCasProcessorList, CPMEngine aEngine, boolean redeploy)
Deploys integrated Cas Processor.Methods in org.apache.uima.collection.impl.cpm.container.deployer with parameters of type ProcessingContainer Modifier and Type Method Description void
CPEDeployerDefaultImpl. deployCasProcessor(ProcessingContainer aProcessingContainer)
Deploys integrated Cas Processor using configuration available in a given Container. -
Uses of ProcessingContainer in org.apache.uima.collection.impl.cpm.container.deployer.socket
Methods in org.apache.uima.collection.impl.cpm.container.deployer.socket that return ProcessingContainer Modifier and Type Method Description ProcessingContainer
SocketCasProcessorDeployer. deployCasProcessor(java.util.List aCasProcessorList, boolean redeploy)
Uses ProcessControllerAdapter instance to launch fenced CasProcessor.ProcessingContainer
SocketCasProcessorDeployer. deployCasProcessor(java.util.List aCasProcessorList, CPMEngine aEngine, boolean redeploy)
Deploys integrated Cas Processor.Methods in org.apache.uima.collection.impl.cpm.container.deployer.socket with parameters of type ProcessingContainer Modifier and Type Method Description void
SocketCasProcessorDeployer. deployCasProcessor(ProcessingContainer aProcessingContainer)
Uses ProcessControllerAdapter instance to launch fenced CasProcessor. -
Uses of ProcessingContainer in org.apache.uima.collection.impl.cpm.container.deployer.vinci
Methods in org.apache.uima.collection.impl.cpm.container.deployer.vinci that return ProcessingContainer Modifier and Type Method Description ProcessingContainer
VinciCasProcessorDeployer. deployCasProcessor(java.util.List aCasProcessorList, boolean redeploy)
Deploys CasProcessors in a provided List.ProcessingContainer
VinciCasProcessorDeployer. deployCasProcessor(java.util.List aCasProcessorList, CPMEngine aEngine, boolean redeploy)
Deploys integrated Cas Processor.Methods in org.apache.uima.collection.impl.cpm.container.deployer.vinci with parameters of type ProcessingContainer Modifier and Type Method Description private boolean
VinciCasProcessorDeployer. activateProcessor(CasProcessorConfiguration aCasProcessorConfig, java.lang.String aHost, int aPort, ProcessingContainer aProcessingContainer, boolean redeploy)
Creates a proxy and connects it to Vinci service running on a given port.private boolean
VinciCasProcessorDeployer. activateProcessor(CasProcessorConfiguration aCasProcessorConfig, java.lang.String aService, ProcessingContainer aProcessingContainer, boolean redeploy)
Creates a proxy and connects it to Vinci service.private void
VinciCasProcessorDeployer. associateMetadataWithContainer(ProcessingContainer aProcessingContainer)
Retrieve the metadata from the service and add it to the container.private int
VinciCasProcessorDeployer. attachToServices(boolean redeploy, java.lang.String aServiceUri, int howMany, ProcessingContainer aProcessingContainer)
Create and attach a proxies to vinci services.private void
VinciCasProcessorDeployer. bindProxyToNetworkCasProcessor(VinciTAP aTap, ProcessingContainer aProcessingContainer, boolean redeploy)
Associates connected proxy with an instance of CasProcessor.private void
VinciCasProcessorDeployer. connectToServices(ProcessingContainer aProcessingContainer, CasProcessorConfiguration casProcessorConfig, boolean redeploy, int howMany)
This method is used during a launch of the local or managed Cas Processor.private void
VinciCasProcessorDeployer. deployBasedOnModel(ProcessingContainer aProcessingContainer, CasProcessorConfiguration aCasProcessorConfig, boolean redeploy)
Deploys CasProcessor according to configured deployment mode.void
VinciCasProcessorDeployer. deployCasProcessor(ProcessingContainer aProcessingContainer)
Deploys CasProcessor using configuration from provided container.private void
VinciCasProcessorDeployer. deployIntegrated(ProcessingContainer aProcessingContainer, boolean redeploy)
No-op for integrated deployment.private void
VinciCasProcessorDeployer. deployLocal(ProcessingContainer aProcessingContainer, boolean redeploy)
Deploys CasProcessor as a Local Vinci Service.private void
VinciCasProcessorDeployer. deployRemote(ProcessingContainer aProcessingContainer, boolean redeploy)
Deploys CasProcessor as a remote/network service.private void
VinciCasProcessorDeployer. handleMaxRestartThresholdReached(ProcessingContainer aProcessingContainer)
Handles situation when max restart threshold is reached while connecting to CasProcessor.private void
VinciCasProcessorDeployer. launchLocalService(ProcessingContainer aProcessingContainer, CasProcessorConfiguration casProcessorConfig, boolean redeploy, int howMany)
Launches an application as a seperate process using java's Process object. -
Uses of ProcessingContainer in org.apache.uima.collection.impl.cpm.engine
Methods in org.apache.uima.collection.impl.cpm.engine with parameters of type ProcessingContainer Modifier and Type Method Description private boolean
NonThreadedProcessingUnit. containerDisabled(ProcessingContainer aContainer)
Container disabled.private boolean
ProcessingUnit. containerDisabled(ProcessingContainer aContainer)
Container disabled.private void
NonThreadedProcessingUnit. doEndOfBatch(ProcessingContainer aContainer, CasProcessor aProcessor, ProcessTrace aProcessTr, int howManyCases)
Do end of batch.private void
ProcessingUnit. doEndOfBatch(ProcessingContainer aContainer, CasProcessor aProcessor, ProcessTrace aProcessTr, int howManyCases)
Do end of batch.private void
ProcessingUnit. doEndOfBatchProcessing(ProcessingContainer aContainer, CasProcessor aProcessor, ProcessTrace aProcessTr, java.lang.Object[] aCasObjectList)
Performs end of batch processing.private void
NonThreadedProcessingUnit. doReleaseCasProcessor(ProcessingContainer aContainer, CasProcessor aCasProcessor)
Do release cas processor.private void
ProcessingUnit. doReleaseCasProcessor(ProcessingContainer aContainer, CasProcessor aCasProcessor)
Do release cas processor.private boolean
NonThreadedProcessingUnit. filterOutTheCAS(ProcessingContainer aContainer, boolean isCasObject, java.lang.Object[] aCasObjectList)
Filter out the CAS.private boolean
ProcessingUnit. filterOutTheCAS(ProcessingContainer aContainer, boolean isCasObject, java.lang.Object[] aCasObjectList)
Filter out the CAS.private java.util.HashMap
CPMEngine. getStatForContainer(ProcessingContainer aContainer)
Gets the stat for container.private void
ProcessingUnit. handleAbortCasProcessor(ProcessingContainer aContainer, CasProcessor aProcessor)
Diables currect CasProcessor.private void
ProcessingUnit. handleAbortCPM(ProcessingContainer aContainer, CasProcessor aProcessor)
Terminates the CPM.private boolean
NonThreadedProcessingUnit. handleErrors(java.lang.Throwable e, ProcessingContainer aContainer, CasProcessor aProcessor, ProcessTrace aProcessTrace, java.lang.Object[] aCasObjectList, boolean isCasObject)
Main routine that handles errors occuring in the processing loop.private boolean
ProcessingUnit. handleErrors(java.lang.Throwable e, ProcessingContainer aContainer, CasProcessor aProcessor, ProcessTrace aProcessTrace, java.lang.Object[] aCasObjectList, boolean isCasObject)
Main routine that handles errors occuring in the processing loop.private void
ProcessingUnit. handleKillPipeline(ProcessingContainer aContainer)
Terminates the CPM.private void
NonThreadedProcessingUnit. handleServiceException(ProcessingContainer aContainer, CasProcessor aProcessor, ProcessTrace aProcessTr, java.lang.Exception ex)
Handle service exception.private void
ProcessingUnit. handleServiceException(ProcessingContainer aContainer, CasProcessor aProcessor, ProcessTrace aProcessTr, java.lang.Exception ex)
Handle exceptions related to remote invocations.private void
NonThreadedProcessingUnit. handleSkipCasProcessor(ProcessingContainer aContainer, java.lang.Object[] aCasObjectList, boolean isLastCP)
Handle skip cas processor.private void
ProcessingUnit. handleSkipCasProcessor(ProcessingContainer aContainer, java.lang.Object[] aCasObjectList, boolean isLastCP)
In case a CAS is skipped ( due to excessive exceptions that it causes ), increments stats and totals.private void
NonThreadedProcessingUnit. invokeCasDataCasProcessor(ProcessingContainer container, CasProcessor processor, java.lang.Object[] aCasObjectList, ProcessTrace pTrTemp, boolean isCasObject, boolean retry)
Invoke cas data cas processor.private void
ProcessingUnit. invokeCasDataCasProcessor(ProcessingContainer container, CasProcessor processor, java.lang.Object[] aCasObjectList, ProcessTrace pTrTemp, boolean isCasObject, boolean retry)
Invoke cas data cas processor.private void
NonThreadedProcessingUnit. invokeCasObjectCasProcessor(ProcessingContainer container, CasProcessor processor, java.lang.Object[] aCasObjectList, ProcessTrace pTrTemp, boolean isCasObject)
Invoke cas object cas processor.private void
ProcessingUnit. invokeCasObjectCasProcessor(ProcessingContainer container, CasProcessor processor, java.lang.Object[] aCasObjectList, ProcessTrace pTrTemp, boolean isCasObject)
Invoke cas object cas processor.private void
ProcessingUnit. logFinest(java.lang.String msgBundleId, ProcessingContainer container, CasProcessor processor)
Log finest.private void
ProcessingUnit. maybeLogFinest(java.lang.String msgBundleId, ProcessingContainer container)
Maybe log finest.private void
ProcessingUnit. maybeLogFinest(java.lang.String msgBundleId, ProcessingContainer container, CasProcessor processor)
Maybe log finest.private void
ProcessingUnit. maybeLogFinest(java.lang.String msgBundleId, ProcessingContainer container, CasProcessor processor, CAS[] casCache)
Maybe log finest.private boolean
NonThreadedProcessingUnit. pauseContainer(ProcessingContainer aContainer, java.lang.Exception aException, java.lang.String aThreadId)
Determines if the thread should be paused.private boolean
ProcessingUnit. pauseContainer(ProcessingContainer aContainer, java.lang.Exception aException, java.lang.String aThreadId)
Determines if the thread should be paused.void
CPMEngine. redeployAnalysisEngine(ProcessingContainer aProcessingContainer)
Deploys CasProcessor and associates it with aProcessingContainer
.private void
CPMEngine. saveStat(java.lang.String aStatLabel, java.lang.String aStatValue, ProcessingContainer aContainer)
Save stat.
-