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