Examples of releaseCasProcessor()

Examples of org.apache.uima.collection.impl.base_cpm.container.ProcessingContainer.releaseCasProcessor()

2813
2814
2815
2816
2817
2818
2819
2820
2821
2822
2823
        }
        CasProcessor processor = container.getCasProcessor();
        if (processor instanceof CasObjectProcessor) {
          ((CasObjectProcessor) processor).typeSystemInit(cas.getTypeSystem());
        }
        container.releaseCasProcessor(processor);
      }
      for (int i = 0; i < consumerList.size(); i++) {
        ProcessingContainer container = (ProcessingContainer) consumerList.get(i);
        if (container.getStatus() == Constants.CAS_PROCESSOR_DISABLED) {
          continue; // skip over disabled CasProcessors
View Full Code Here

Examples of org.apache.uima.collection.impl.base_cpm.container.ProcessingContainer.releaseCasProcessor()

2824
2825
2826
2827
2828
2829
2830
2831
2832
2833
2834
        }
        CasProcessor processor = container.getCasProcessor();
        if (processor instanceof CasObjectProcessor) {
          ((CasObjectProcessor) processor).typeSystemInit(cas.getTypeSystem());
        }
        container.releaseCasProcessor(processor);
      }
    } catch (ResourceInitializationException e) {
      throw e;
    } catch (Exception e) {
      throw new ResourceInitializationException(e);
View Full Code Here

Examples of org.apache.uima.collection.impl.base_cpm.container.ProcessingContainer.releaseCasProcessor()

2752
2753
2754
2755
2756
2757
2758
2759
2760
2761
2762
        if (md != null) {
          manager.addMetaData(md);
        }
      }
      finally {
        container.releaseCasProcessor(processor);
      }
    }
    for (int i = 0; i < consumerList.size(); i++) {
      ProcessingContainer container = (ProcessingContainer) consumerList.get(i);
      if (container.getStatus() == Constants.CAS_PROCESSOR_DISABLED) {
View Full Code Here

Examples of org.apache.uima.collection.impl.base_cpm.container.ProcessingContainer.releaseCasProcessor()

2784
2785
2786
2787
2788
2789
2790
2791
2792
2793
2794
        if (md != null) {
          manager.addMetaData(md);
        }
      }
      finally {
        container.releaseCasProcessor(processor);
      }
    }
  }

  /**
 
View Full Code Here

Examples of org.apache.uima.collection.impl.base_cpm.container.ProcessingContainer.releaseCasProcessor()

2815
2816
2817
2818
2819
2820
2821
2822
2823
2824
2825
        }
        CasProcessor processor = container.getCasProcessor();
        if (processor instanceof CasObjectProcessor) {
          ((CasObjectProcessor) processor).typeSystemInit(cas.getTypeSystem());
        }
        container.releaseCasProcessor(processor);
      }
      for (int i = 0; i < consumerList.size(); i++) {
        ProcessingContainer container = (ProcessingContainer) consumerList.get(i);
        if (container.getStatus() == Constants.CAS_PROCESSOR_DISABLED) {
          continue; // skip over disabled CasProcessors
View Full Code Here

Examples of org.apache.uima.collection.impl.base_cpm.container.ProcessingContainer.releaseCasProcessor()

2826
2827
2828
2829
2830
2831
2832
2833
2834
2835
2836
        }
        CasProcessor processor = container.getCasProcessor();
        if (processor instanceof CasObjectProcessor) {
          ((CasObjectProcessor) processor).typeSystemInit(cas.getTypeSystem());
        }
        container.releaseCasProcessor(processor);
      }
    } catch (ResourceInitializationException e) {
      throw e;
    } catch (Exception e) {
      throw new ResourceInitializationException(e);
View Full Code Here

Examples of org.apache.uima.collection.impl.base_cpm.container.ProcessingContainer.releaseCasProcessor()

1408
1409
1410
1411
1412
1413
1414
1415
1416
1417
1418
                      new Object[] { Thread.currentThread().getName(), container.getName() });
            }
            // Release current Cas Processor before continuing with the next Cas Processor in the
            // pipeline
            if (processor != null) {
              container.releaseCasProcessor(processor);
              if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
                UIMAFramework.getLogger(this.getClass()).logrb(Level.FINEST,
                        this.getClass().getName(), "process", CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
                        "UIMA_CPM_ok_released_cp__FINEST",
                        new Object[] { Thread.currentThread().getName(), container.getName() });
View Full Code Here

Examples of org.apache.uima.collection.impl.base_cpm.container.ProcessingContainer.releaseCasProcessor()

1459
1460
1461
1462
1463
1464
1465
1466
1467
1468
1469
            // - terminates CPM when threshold is reached ( method below throws AbortCPMException)
            // - disables CasProcessor ( method below throws AbortCasProcessorException )
            // - continue, CasProcessor continues to run dispite error
            container.incrementCasProcessorErrors(e);

            container.releaseCasProcessor(processor);
            processor = null;
            if (cpm.dropCasOnException()) {
              // Cas has already been returned to the CAS pool. The policy requires to stop the
              // processing chain for this CAS and
              // to get another CAS for processing.
View Full Code Here

Examples of org.apache.uima.collection.impl.base_cpm.container.ProcessingContainer.releaseCasProcessor()

1583
1584
1585
1586
1587
1588
1589
1590
1591
1592
1593
          } catch (SkipCasException ex) {
            try {
              // Release current Cas Processor before continuing with the next Cas Processor in the
              // pipeline
              if (processor != null) {
                container.releaseCasProcessor(processor);
              }

              handleSkipCasProcessor(container, aCasObjectList,
                      (i == (processContainers.size() - 1)));
            } catch (Exception sEx) {
View Full Code Here

Examples of org.apache.uima.collection.impl.base_cpm.container.ProcessingContainer.releaseCasProcessor()

1652
1653
1654
1655
1656
1657
1658
1659
1660
1661
1662
                CPMUtils.CPM_LOG_RESOURCE_BUNDLE,
                "UIMA_CPM_release_cp__FINEST",
                new Object[] { Thread.currentThread().getName(), container.getName(),
                    processor.getClass().getName(), String.valueOf(casCache == null) });

        container.releaseCasProcessor(processor);
        processor = null;
        if (UIMAFramework.getLogger().isLoggable(Level.FINEST)) {
          UIMAFramework.getLogger(this.getClass()).logrb(
                  Level.FINEST,
                  this.getClass().getName(),
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.