public class FilesInDirectoryCollectionCyclicalReads extends FilesInDirectoryCollectionReader
Modifier and Type | Field and Description |
---|---|
private int |
iv_iteration |
static java.lang.String |
PARAM_ENCODING
Name of configuration parameter that contains the character encoding used
by the input files.
|
static java.lang.String |
PARAM_EXTENSIONS
Name of optional configuration parameter that specifies the extensions
of the files that the collection reader will read.
|
static java.lang.String |
PARAM_INPUTDIR
Name of configuration parameter that must be set to the path of
a directory containing input files.
|
static java.lang.String |
PARAM_LANGUAGE
Name of optional configuration parameter that contains the language of
the documents in the input directory.
|
static java.lang.String |
PARAM_NUMREADS
Arguement to equate to # of times it should read the files.
|
static java.lang.String |
PARAM_RECURSE |
private int |
remainTimes |
private int |
scaleTime |
private int |
totalNumFiles |
iv_currentIndex, iv_files
Constructor and Description |
---|
FilesInDirectoryCollectionCyclicalReads() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
getNext(CAS aCAS) |
int |
getNumberOfDocuments()
Gets the total number of documents that will be returned by this
collection reader.
|
Progress[] |
getProgress() |
boolean |
hasNext()
Similar to 'org.apache.uima.collection.CollectionReader' method hasNext() except
interations represents the actual number of documents to be processed, so if the
total number of documents in a queue is more than the 'Iterations' value then only
the iteration amount will be processed.
|
void |
initialize() |
public static final java.lang.String PARAM_INPUTDIR
public static final java.lang.String PARAM_ENCODING
public static final java.lang.String PARAM_LANGUAGE
public static final java.lang.String PARAM_EXTENSIONS
'.'
.public static final java.lang.String PARAM_NUMREADS
public static final java.lang.String PARAM_RECURSE
private int iv_iteration
private int scaleTime
private int totalNumFiles
private int remainTimes
public FilesInDirectoryCollectionCyclicalReads()
public void initialize() throws ResourceInitializationException
initialize
in class FilesInDirectoryCollectionReader
ResourceInitializationException
org.apache.uima.collection.CollectionReader_ImplBase#initialize()
public boolean hasNext()
hasNext
in class FilesInDirectoryCollectionReader
org.apache.uima.collection.CollectionReader#hasNext()
public void getNext(CAS aCAS) throws java.io.IOException, CollectionException
getNext
in class FilesInDirectoryCollectionReader
java.io.IOException
CollectionException
org.apache.uima.collection.CollectionReader#getNext(org.apache.uima.cas.CAS)
public void close() throws java.io.IOException
close
in class FilesInDirectoryCollectionReader
java.io.IOException
org.apache.uima.collection.base_cpm.BaseCollectionReader#close()
public Progress[] getProgress()
getProgress
in class FilesInDirectoryCollectionReader
org.apache.uima.collection.base_cpm.BaseCollectionReader#getProgress()
public int getNumberOfDocuments()
getNumberOfDocuments
in class FilesInDirectoryCollectionReader