import org.apache.uima.util.Progress; //导入依赖的package包/类
@Test
public void test() throws Exception {
	FakeCollectionReader cr = new FakeCollectionReader();

	UimaContext context = UimaContextFactory.createUimaContext();
	cr.initialize(context);
	assertTrue(cr.initialised);

	assertNotNull(cr.getSupport());
	assertNotNull(cr.getMonitor());
	assertNotNull(cr.getProgress());

	Progress[] progress = cr.getProgress();
	assertEquals("testunits", progress[0].getUnit());

	assertFalse(cr.hasNext());
	assertTrue(cr.hasNext);

	cr.getNext((JCas)null);
	assertTrue(cr.getNext);

	cr.destroy();
	assertTrue(cr.closed);
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
public Progress[] getProgress() {
	return new Progress[] {
			new ProgressImpl(
					Long.valueOf(currentRecord).intValue(),
					Long.valueOf(totalRecords).intValue(),
					Progress.ENTITIES
					)
	};
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
public Progress[] getProgress() {
	return new Progress[] {
			new ProgressImpl(
					Long.valueOf(currentRecord).intValue() - 1,
					Long.valueOf(totalRecords).intValue(),
					Progress.ENTITIES
					)
	};
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
@Override
public Progress[] getProgress() {
	if (disableProgressTracking) {
		documentsToBeProcessedCount = processedDocumentCount + 1;
	}
	return new Progress[] { new ProgressImpl(processedDocumentCount, documentsToBeProcessedCount, Progress.ENTITIES) };
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public Progress[] getProgress() {
    return new Progress[]{
            new ProgressImpl(lastReadFileIdx + 1, files.size(), Progress.ENTITIES)
    };
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public Progress[] getProgress() {
    return new Progress[]{
            new ProgressImpl(consumedCount, expectedTotalCount, Progress.ENTITIES)
    };
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
@Override
public Progress[] getProgress() {
    int filesRead = lastReadFileIndex + 1;
    return new Progress[]{
            new ProgressImpl(filesRead, inputFiles.size(), Progress.ENTITIES)
    };
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
@Override
public final Progress[] getProgress() {
	monitor.startFunction("getProgress");

	Progress[] ret = doGetProgress();

	monitor.finishFunction("getProgress");
	return ret;
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
public Progress[] getProgress() {
  if (filterArticles) {
    return new Progress[] { new ProgressImpl(progress, articleIds.size(), Progress.ENTITIES) };
  } else {
    return new Progress[] { new ProgressImpl(progress, 2000, Progress.ENTITIES) };
  }
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
/**
 *
 * @return an array of Progress objects. Each object may have different units (for example number of entities or bytes).
 */
@Override
public Progress[] getProgress() {
    return new Progress[]{new ProgressImpl(getCurrentIndex(),
            getCollectionSize(),
            Progress.ENTITIES)};
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
@Test
public void testRunWithPropertySetting() throws Exception {
    DatabaseCollectionReader dcr = new DatabaseCollectionReader()
            .setQuery(query)
            .setIdColumn("id")
            .setNoteColumn("note")
            .setDriver(dbConnectionInfo.getDriver())
            .setURL(dbConnectionInfo.getUrl())
            .setUsername(dbConnectionInfo.getUsername())
            .setPassword(dbConnectionInfo.getPassword());
    assertNotNull(dcr);
    assertEquals(dbConnectionInfo.getDriver(), dcr.getDriver());
    assertEquals(dbConnectionInfo.getUrl(), dcr.getURL());
    assertEquals(dbConnectionInfo.getUsername(), dcr.getUsername());
    assertEquals(dbConnectionInfo.getPassword(), dcr.getPassword());
    assertEquals(query, dcr.getQuery());
    assertEquals("id", dcr.getIdColumn());
    assertEquals("note", dcr.getNoteColumn());

    //Create the mock client and run it
    DoNothingListener listener = new DoNothingListener();
    assertNotNull(listener);
    MockClient client = new MockClient();
    assertNotNull(client);
    client.run(dcr, listener);
    //Check that all records were pulled
    assertEquals(TEST_CORPUS_SIZE, listener.getNumReceived());
    Progress progress = dcr.getProgress()[0];
    assertEquals(0, progress.getCompleted());
    assertEquals(0, progress.getTotal());
    assertEquals("row(s)", progress.getUnit());
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
@Override
public Progress[] getProgress()
{
    // empty as we don't know how many entries are in the tar stream...
    return new Progress[] {};
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
public Progress[] getProgress()
{
    return null;
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
@Override
public Progress[] getProgress() {
  return new Progress[]{new ProgressImpl(completed, total, "Documents", true)};
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
@Override
public Progress[] getProgress() {
  return new Progress[0];
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
@Override
public Progress[] getProgress() {
	return null;
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
public Progress[] getProgress() {
    int total = resourcesNum == null ? -1 : resourcesNum;
    return new Progress[]{new ProgressImpl(resourcesRead, total, Progress.ENTITIES)};
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public Progress[] getProgress() {
    return null;
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
@Override
public Progress[] getProgress() {
    return new Progress[]{new ProgressImpl(mCurrentIndex,
            uriAnnotatorPairs.size(), Progress.ENTITIES)};
}
 

import org.apache.uima.util.Progress; //导入依赖的package包/类
@Override
public Progress[] getProgress() {
    return new Progress[]{
            new ProgressImpl(docsRead, totalDocsNum, Progress.ENTITIES)
    };
}