Examples of addCollectionReader()

Examples of org.apache.uima.collection.metadata.CpeDescription.addCollectionReader()

372
373
374
375
376
377
378
379
380
381
382
      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);
View Full Code Here

Examples of org.apache.uima.collection.metadata.CpeDescription.addCollectionReader()

731
732
733
734
735
736
737
738
739
740
741
         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);
View Full Code Here

Examples of org.apache.uima.collection.metadata.CpeDescription.addCollectionReader()

151
152
153
154
155
156
157
158
159
160
161
              .produceCasProcessor("ErrorTest CasConsumer");
      casConsumer.setDescriptor(casConsumerDesc);
      cpeDesc.addCasProcessor(casConsumer);

      // add collectionReader
      cpeDesc.addCollectionReader(colReaderDesc);

      // produce cpe
      cpe = UIMAFramework.produceCollectionProcessingEngine(cpeDesc, null, null);
    } catch (Exception e) {
      e.printStackTrace();
View Full Code Here

Examples of org.apache.uima.collection.metadata.CpeDescription.addCollectionReader()

250
251
252
253
254
255
256
257
258
259
260
              .produceCasProcessor("ErrorTest CasConsumer");
      casConsumer.setDescriptor(casConsumerDesc);
      cpeDesc.addCasProcessor(casConsumer);

      // add collectionReader
      cpeDesc.addCollectionReader(colReaderDesc);

      // produce cpe
      cpe = UIMAFramework.produceCollectionProcessingEngine(cpeDesc, null, null);
    } catch (Exception e) {
      e.printStackTrace();
View Full Code Here

Examples of org.apache.uima.collection.metadata.CpeDescription.addCollectionReader()

193
194
195
196
197
198
199
200
201
202
203
              .produceCasProcessor("ErrorTest CasConsumer");
      casConsumer.setDescriptor(casConsumerDesc);
      cpeDesc.addCasProcessor(casConsumer);

      // add collectionReader
      cpeDesc.addCollectionReader(colReaderDesc);

      // produce cpe
      cpe = UIMAFramework.produceCollectionProcessingEngine(cpeDesc, resourceManager, null);
    } catch (Exception e) {
      e.printStackTrace();
View Full Code Here

Examples of org.apache.uima.collection.metadata.CpeDescription.addCollectionReader()

887
888
889
890
891
892
893
894
895
896
897
        if (list != null && list.size() > 0) {
            String aCollectionReaderPath = "";
            CpeCollectionReader cr = null;
            aCollectionReaderPath = ((UimaCollectionReader)list.get(0)).getXmlDescriptor();
            if (resolve) {
                cr = cpeDesc.addCollectionReader(resolveUimaXmlDescriptor(aCollectionReaderPath));
            } else {
                cr = cpeDesc.addCollectionReader(aCollectionReaderPath);
            }

            // Add Configuration Parameter Overrides for CPE
View Full Code Here

Examples of org.apache.uima.collection.metadata.CpeDescription.addCollectionReader()

889
890
891
892
893
894
895
896
897
898
899
            CpeCollectionReader cr = null;
            aCollectionReaderPath = ((UimaCollectionReader)list.get(0)).getXmlDescriptor();
            if (resolve) {
                cr = cpeDesc.addCollectionReader(resolveUimaXmlDescriptor(aCollectionReaderPath));
            } else {
                cr = cpeDesc.addCollectionReader(aCollectionReaderPath);
            }

            // Add Configuration Parameter Overrides for CPE
            UimaCollectionReader ucr = (UimaCollectionReader)list.get(0);
            if (ucr.getConfigParamsModel() != null) {
View Full Code Here

Examples of org.apache.uima.collection.metadata.CpeDescription.addCollectionReader()

119
120
121
122
123
124
125
126
127
128
129
      // build a Collection Processing Engine descriptor that will drive processing
      CpeDescription cpeDesc = CpeDescriptorFactory.produceDescriptor();

      // add collection reader that will read input docs
      cpeDesc.addCollectionReader(FileSystemCollectionReader.getDescriptorURL().toString());
      // specify configuration parameters for collection reader
      CasProcessorConfigurationParameterSettings crSettings = CpeDescriptorFactory
              .produceCasProcessorConfigurationParameterSettings();
      CpeCollectionReader cpeCollRdr = cpeDesc.getAllCollectionCollectionReaders()[0];
      cpeCollRdr.setConfigurationParameterSettings(crSettings);
View Full Code Here

Examples of org.apache.uima.collection.metadata.CpeDescription.addCollectionReader()

114
115
116
117
118
119
120
121
122
123
124
      // build a Collection Processing Engine descriptor that will drive processing
      CpeDescription cpeDesc = CpeDescriptorFactory.produceDescriptor();

      // add collection reader that will read input docs
      cpeDesc.addCollectionReader(FileSystemCollectionReader.getDescriptorURL().toString());
      // specify configuration parameters for collection reader
      CasProcessorConfigurationParameterSettings crSettings = CpeDescriptorFactory
              .produceCasProcessorConfigurationParameterSettings();
      CpeCollectionReader cpeCollRdr = cpeDesc.getAllCollectionCollectionReaders()[0];
      cpeCollRdr.setConfigurationParameterSettings(crSettings);
View Full Code Here

Examples of org.apache.uima.collection.metadata.CpeDescription.addCollectionReader()

387
388
389
390
391
392
393
394
395
396
397
      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);
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.