Package org.apache.uima.collection.metadata

Examples of org.apache.uima.collection.metadata.CpeDescription

665
666
667
668
669
670
671
672
673
674
675
676
    // disable System.out
    ManageOutputDevice.setAllSystemOutputToNirvana();
    Object[] objs = setupConfigurableCpm(documentCount, exceptionName, exceptionSequence,
            functionName);

    CpeDescription cpeDesc = (CpeDescription) objs[0];
    cpeDesc.setProcessingUnitThreadCount(1);
    CpeIntegratedCasProcessor integratedProcessor = (CpeIntegratedCasProcessor) objs[1];
    integratedProcessor.setActionOnMaxError("continue");
    integratedProcessor.setMaxErrorCount(3);
    integratedProcessor.setMaxErrorSampleSize(100);
View Full Code Here
710
711
712
713
714
715
716
717
718
719
720
721
722
    // setup CPM
    Object[] objs = setupConfigurableCpm(documentCount, exceptionName, exceptionSequence,
            functionName);

    CpeDescription cpeDesc = (CpeDescription) objs[0];
    cpeDesc.setProcessingUnitThreadCount(1);
    cpeDesc.setNumToProcess(20);
    CpeIntegratedCasProcessor integratedProcessor = (CpeIntegratedCasProcessor) objs[1];
    integratedProcessor.setActionOnMaxError("terminate");
    CollectionProcessingEngine cpe = UIMAFramework.produceCollectionProcessingEngine(cpeDesc, null,
            null);
View Full Code Here
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
   *
   * @return CollectionProcessingEngine - initialized cpe
   */
  private CollectionProcessingEngine setupCpm(int documentCount, String exceptionName,
          int exceptionSequence, String functionName) {
    CpeDescription cpeDesc = null;
    CollectionProcessingEngine cpe = null;

    try {
      String colReaderBase = JUnitExtension.getFile(
              "CpmTests" + FS + "ErrorTestCollectionReader.xml").getAbsolutePath();
      String taeBase = JUnitExtension.getFile("CpmTests" + FS + "ErrorTestAnnotator.xml")
              .getAbsolutePath();
      String casConsumerBase = JUnitExtension.getFile("CpmTests" + FS + "ErrorTestCasConsumer.xml")
              .getAbsolutePath();

      // first, prepare all descriptors as needed
      String colReaderDesc = DescriptorMakeUtil.makeCollectionReader(colReaderBase, documentCount);
      String taeDesc = DescriptorMakeUtil.makeAnalysisEngine(taeBase, true, functionName,
              exceptionSequence, exceptionName);
      String casConsumerDesc = DescriptorMakeUtil.makeCasConsumer(casConsumerBase);

      // secondly, create the cpm based on the descriptors
      cpeDesc = CpeDescriptorFactory.produceDescriptor();

      // managing the default behaviour of this client
      CpeIntegratedCasProcessor integratedProcessor = CpeDescriptorFactory
              .produceCasProcessor("ErrorTestAnnotator");
      integratedProcessor.setDescriptor(taeDesc);

      CpeIntegratedCasProcessor casConsumer = CpeDescriptorFactory
              .produceCasProcessor("ErrorTest CasConsumer");
      casConsumer.setDescriptor(casConsumerDesc);

      // - add all descriptors
      cpeDesc.addCollectionReader(colReaderDesc);
      cpeDesc.addCasProcessor(integratedProcessor);
      cpeDesc.addCasProcessor(casConsumer);
      cpeDesc.setInputQueueSize(2);
      cpeDesc.setOutputQueueSize(2);
      cpeDesc.setProcessingUnitThreadCount(1);
      // - Create a new CPE
      cpe = UIMAFramework.produceCollectionProcessingEngine(cpeDesc, null, null);
    } catch (Exception e) {
      // e.printStackTrace();
    }
View Full Code Here
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
   *
   * @return Object[] with the cpe-Descriptor at index 0 and the integratedProcessor at index 1
   */
  private Object[] setupConfigurableCpm(int documentCount, String exceptionName,
          int exceptionSequence, String functionName) {
    CpeDescription cpeDesc = null;
    CpeIntegratedCasProcessor integratedProcessor = null;
    try {
      String colReaderBase = JUnitExtension.getFile(
              "CpmTests" + FS + "ErrorTestCollectionReader.xml").getAbsolutePath();
      String taeBase = JUnitExtension.getFile("CpmTests" + FS + "ErrorTestAnnotator.xml")
              .getAbsolutePath();
      String casConsumerBase = JUnitExtension.getFile("CpmTests" + FS + "ErrorTestCasConsumer.xml")
              .getAbsolutePath();

      // first, prepare all descriptors as needed
      String colReaderDesc = DescriptorMakeUtil.makeCollectionReader(colReaderBase, documentCount);
      String taeDesc = null;
      if (exceptionName == null || exceptionSequence <= 0 || functionName == null) {
        taeDesc = DescriptorMakeUtil.makeAnalysisEngine(taeBase);
      } else {
        taeDesc = DescriptorMakeUtil.makeAnalysisEngine(taeBase, true, functionName,
                exceptionSequence, exceptionName);
      }
      String casConsumerDesc = DescriptorMakeUtil.makeCasConsumer(casConsumerBase);

      // secondly, create the cpm based on the descriptors
      cpeDesc = CpeDescriptorFactory.produceDescriptor();

      // managing the default behaviour of this client
      integratedProcessor = CpeDescriptorFactory.produceCasProcessor("ErrorTestAnnotator");
      integratedProcessor.setDescriptor(taeDesc);

      CpeIntegratedCasProcessor casConsumer = CpeDescriptorFactory
              .produceCasProcessor("ErrorTest CasConsumer");
      casConsumer.setDescriptor(casConsumerDesc);

      // - add all descriptors
      cpeDesc.addCollectionReader(colReaderDesc);
      cpeDesc.addCasProcessor(integratedProcessor);
      cpeDesc.addCasProcessor(casConsumer);
      cpeDesc.setInputQueueSize(2);
      cpeDesc.setOutputQueueSize(2);
      // - Create a new CPE

    } catch (Exception e) {
      e.printStackTrace();
    }
View Full Code Here
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
  /**
   * @return
   */
  private CpeDescription createEmptyCpeDescription() {
    CpeDescription cpeDesc = CpeDescriptorFactory.produceDescriptor();
    // We use CAS pool size default of 3
    try {
      CpeCasProcessors cpeCasProcs = CpeDescriptorFactory.produceCasProcessors();
      cpeDesc.setCpeCasProcessors(cpeCasProcs);
      cpeCasProcs.setPoolSize(3);
    } catch (CpeDescriptorException e) {
      e.printStackTrace(); // this should never happen
    }
    return cpeDesc;
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
      Properties newProps = UIMAFramework.getDefaultPerformanceTuningProperties();
      newProps.setProperty(UIMAFramework.CAS_INITIAL_HEAP_SIZE, "100000");
      HashMap params = new HashMap();
      params.put(Resource.PARAM_PERFORMANCE_TUNING_SETTINGS, newProps);

      CpeDescription cpeDesc = UIMAFramework.getXMLParser().parseCpeDescription(
    new XMLInputSource(JUnitExtension
        .getFile("CollectionProcessingEngineImplTest/performanceTuningSettingsTestCpe.xml")));
      CollectionProcessingEngine cpe = UIMAFramework.produceCollectionProcessingEngine(cpeDesc,
    params);
      cpe.process();
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
  public void testExternalResoures() throws Exception {
    try {
      ResourceManager rm = UIMAFramework.newDefaultResourceManager();
      rm.setDataPath(TEST_DATAPATH);
      CpeDescription cpeDesc = UIMAFramework.getXMLParser().parseCpeDescription(
    new XMLInputSource(JUnitExtension
        .getFile("CollectionProcessingEngineImplTest/externalResourceTestCpe.xml")));
      CollectionProcessingEngine cpe = UIMAFramework.produceCollectionProcessingEngine(cpeDesc, rm,
    null);
      CollectionReader colRdr = (CollectionReader) cpe.getCollectionReader();
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
      JUnitExtension.handleException(e);
    }
  }
 
  public void testCasMultiplierTypeSystem() throws Throwable {
    CpeDescription cpeDesc = UIMAFramework.getXMLParser()
            .parseCpeDescription(new XMLInputSource(
                    JUnitExtension.getFile("CollectionProcessingEngineImplTest/cpeWithWrappedCasMultiplier.xml")));
    CollectionProcessingEngine cpe = UIMAFramework.produceCollectionProcessingEngine(cpeDesc);
    // create and register a status callback listener
    TestStatusCallbackListener listener = new TestStatusCallbackListener();
View Full Code Here
289
290
291
292
293
294
295
296
297
298
299
300
301
    }
    checkpointData = aCheckpointData;
    // enProcSt = new EntityProcessStatusImpl(procTr);
    CPEFactory factory = this.cpeFactory;
    if (factory != null) {
      CpeDescription desc = factory.getCpeDescriptor();
      if (desc != null) {
        CpeCasProcessors proc = desc.getCpeCasProcessors();
        if (proc != null) {
          dropCasOnExceptionPolicy = proc.getDropCasOnException();
        }
      }
    }
View Full Code Here
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
    *
    * @return CollectionProcessingEngine - initialized cpe
    */
   private CollectionProcessingEngine setupCpm(int documentCount,
         String exceptionName, int exceptionSequence, String functionName) {
      CpeDescription cpeDesc = null;
      CollectionProcessingEngine cpe = null;

      try {
         String colReaderBase = JUnitExtension.getFile(
               "CpmTests" + FS + "ErrorTestCollectionReader.xml")
               .getAbsolutePath();
         String taeBase = JUnitExtension.getFile(
               "CpmTests" + FS + "ErrorTestAnnotator.xml").getAbsolutePath();
         String casConsumerBase = JUnitExtension.getFile(
               "CpmTests" + FS + "ErrorTestCasConsumer.xml").getAbsolutePath();

         // first, prepare all descriptors as needed
         String colReaderDesc = DescriptorMakeUtil.makeCollectionReader(
               colReaderBase, true, functionName, exceptionSequence,
               exceptionName, documentCount);
         String taeDesc = DescriptorMakeUtil.makeAnalysisEngine(taeBase);
         String casConsumerDesc = DescriptorMakeUtil
               .makeCasConsumer(casConsumerBase);

         // secondly, create the cpm based on the descriptors
         cpeDesc = CpeDescriptorFactory.produceDescriptor();

         // managing the default behaviour of this client
         CpeIntegratedCasProcessor integratedProcessor = CpeDescriptorFactory
               .produceCasProcessor("ErrorTestAnnotator");
         integratedProcessor.setDescriptor(taeDesc);

         CpeIntegratedCasProcessor casConsumer = CpeDescriptorFactory
               .produceCasProcessor("ErrorTest CasConsumer");
         casConsumer.setDescriptor(casConsumerDesc);

         // - add all descriptors
         cpeDesc.addCollectionReader(colReaderDesc);
         cpeDesc.addCasProcessor(integratedProcessor);
         cpeDesc.addCasProcessor(casConsumer);
         cpeDesc.setInputQueueSize(2);
         cpeDesc.setOutputQueueSize(2);
         cpeDesc.setProcessingUnitThreadCount(1);
         // - Create a new CPE
         cpe = UIMAFramework.produceCollectionProcessingEngine(cpeDesc, null,
               null);
      } catch (Exception e) {
         e.printStackTrace();
View Full Code Here
TOP

Related Classes of org.apache.uima.collection.metadata.CpeDescription

  • org.apache.ctakes.core.cpe.CmdLineCpeRunner
  • org.apache.ctakes.postagger.test.CpeTests
  • org.apache.ctakes.regression.test.RegressionPipelineTest
  • org.apache.ctakes.ytex.tools.RunCPE
  • org.apache.uima.application.metadata.impl.UimaApplication_Impl
  • org.apache.uima.collection.impl.CollectionProcessingEngine_implTest
  • org.apache.uima.collection.impl.cpm.CasPoolTest
  • org.apache.uima.collection.impl.cpm.CpeDescriptorSerialization_Test
  • org.apache.uima.collection.impl.cpm.CpeImportTest
  • org.apache.uima.collection.impl.cpm.CpmAE_ErrorTest
    • Copyright © 2018 www.massapicom. 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.