import org.apache.uima.collection.CollectionProcessingEngine; //导入依赖的package包/类
public static void main(String[] args) throws IOException, UIMAException,
        CpeDescriptorException {
    if (args.length != 1) {
        System.err.println("Usage: <cpeDescriptorPath>");
        return;
    }
    String cpeDescPath = args[0];

    XMLInputSource cpeDescSource = new XMLInputSource(cpeDescPath);
    CpeDescription cpeDesc = UIMAFramework.getXMLParser().parseCpeDescription(cpeDescSource);

    // produce
    CollectionProcessingEngine cpe = UIMAFramework
            .produceCollectionProcessingEngine(cpeDesc);
    cpe.addStatusCallbackListener(new ReportingStatusCallbackListener(cpe));

    // run
    cpe.process();
}
 

import org.apache.uima.collection.CollectionProcessingEngine; //导入依赖的package包/类
@Override
public Boolean process() throws ResourceInitializationException,
        CpeDescriptorException {
    StatusCallbackListenerSlf4J listener = new StatusCallbackListenerSlf4J();
    CollectionProcessingEngine cpe = createCpe(listener);
    listener.setCpe(cpe);// workaround to get performanceReports

    cpe.process();
    StatusCallbackListenerSlf4J callback = (StatusCallbackListenerSlf4J) listener;
    while (!callback.isCollectionProcessComplete()) {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            throw new RuntimeException("should not happen, though...");
        }
    }
    StopwatchUtils.closeAndPrint(); // close all stopwatches (for profiling)
    return true;
}
 

import org.apache.uima.collection.CollectionProcessingEngine; //导入依赖的package包/类
public static void main(String[] args) throws IOException, UIMAException,
        CpeDescriptorException {
    if (args.length != 2) {
        System.err.println("Usage: <txtInputDir> <xmiOutputDir>");
        return;
    }
    String cpeDescPath = "desc/cpe/cpe-txt-to-xmi.xml";
    String inputDirPath = args[0];
    String outputDirPath = args[1];

    XMLInputSource cpeDescSource = new XMLInputSource(cpeDescPath);
    CpeDescription cpeDesc = UIMAFramework.getXMLParser().parseCpeDescription(cpeDescSource);

    // configure reader
    cpeDesc.getAllCollectionCollectionReaders()[0]
            .getConfigurationParameterSettings().setParameterValue("DirectoryPath",
            inputDirPath);

    // configure writer
    cpeDesc.getCpeCasProcessors().getAllCpeCasProcessors()[0]
            .getConfigurationParameterSettings()
            .setParameterValue("XmiOutputDir", outputDirPath);

    // produce
    CollectionProcessingEngine cpe = UIMAFramework
            .produceCollectionProcessingEngine(cpeDesc);
    cpe.addStatusCallbackListener(new ReportingStatusCallbackListener(cpe));

    // run
    cpe.process();
}
 

import org.apache.uima.collection.CollectionProcessingEngine; //导入依赖的package包/类
public CollectionProcessingEngine createCpe(StatusCallbackListener aListener)
        throws ResourceInitializationException, CpeDescriptorException {
    ResourceManager resMgr = UIMAFramework.newDefaultResourceManager();

    // max errors
    if (maxErrors != 0) {
        for (CpeCasProcessor cpeCasProcessor : cpeDesc
                .getCpeCasProcessors().getAllCpeCasProcessors()) {
            if (maxErrors == -1) // infinite nr errors ok
                cpeCasProcessor.setActionOnMaxError("continue");
            else if (maxErrors > 0)
                cpeCasProcessor.setMaxErrorCount(maxErrors);
        }
    }

    // thread cnt
    if (maxProcessingUnitThreatCount == 0) {
        cpeDesc.getCpeCasProcessors().setPoolSize(3);
    } else {
        cpeDesc.getCpeCasProcessors().setPoolSize(
                maxProcessingUnitThreatCount + 2);
        cpeDesc.setProcessingUnitThreadCount(maxProcessingUnitThreatCount);
    }

    CollectionProcessingEngine cpe = UIMAFramework
            .produceCollectionProcessingEngine(cpeDesc, resMgr, null);
    cpe.addStatusCallbackListener(aListener);
    return cpe;
}
 

import org.apache.uima.collection.CollectionProcessingEngine; //导入依赖的package包/类
/**
 * @param args
 * @throws IOException 
 * @throws InvalidXMLException 
 * @throws ResourceInitializationException 
 */
public static void main(String[] args) throws InvalidXMLException, IOException, ResourceInitializationException {
	
	CpeDescription cpeDesc = UIMAFramework.getXMLParser().
	        parseCpeDescription(new XMLInputSource(desc_fname));
	      
	//instantiate CPE
	CollectionProcessingEngine mCPE = UIMAFramework.produceCollectionProcessingEngine(cpeDesc);
	
	mCPE.process();
}
 

import org.apache.uima.collection.CollectionProcessingEngine; //导入依赖的package包/类
public TestCPERunner(CollectionProcessingEngine collectionProcessingEngine) {
  this.collectionProcessingEngine = collectionProcessingEngine;
}
 

import org.apache.uima.collection.CollectionProcessingEngine; //导入依赖的package包/类
public ReportingStatusCallbackListener(CollectionProcessingEngine cpe) {
    this(cpe, 0);
}
 

import org.apache.uima.collection.CollectionProcessingEngine; //导入依赖的package包/类
public void setCpe(CollectionProcessingEngine cpe) {
    this.cpe = cpe;
}