org.apache.uima.collection.impl.cpm.container
public class CPEFactory extends java.lang.Object
Using objects representing configuration, this component creates CollectionReader CasInitializer, Analysis Engines, and Cas Consumers.
In addition to creating object, this component provides read/write access to the object model allowing for dynamic or programmatic modifications. It facilitates plugging in existing CollectionReaders and CasProcessors.
Modifier and Type | Field and Description |
---|---|
java.util.HashMap |
casProcessorConfigMap |
static java.lang.String |
CPM_HOME |
Constructor and Description |
---|
CPEFactory(CpeDescription aDescriptor,
ResourceManager aResourceManager)
Create a new CPEFactory for a CpeDescription that's already been parsed.
|
CPEFactory(ResourceManager aResourceManager)
Create a new CPEFactory on which we will later call parse(String) to parse a CPE descriptor.
|
Modifier and Type | Method and Description |
---|---|
void |
addCasProcessor(CasProcessor aCasProcessor)
Appends given Cas Processor to the list of CasProcessors
|
void |
addCollectionReader(BaseCollectionReader collectionReader) |
CasProcessor[] |
getCasProcessors()
Returns an array of Cas Processors instantiated from the cpe descriptor
|
BaseCollectionReader |
getCollectionReader()
Returns Collection Reader instantiated from configuration in the cpe descriptor.
|
CpeConfiguration |
getCPEConfig()
Returns an object containing global CPE configuration including:
Number of documents to process
Checkpoint configuration
id of the document begin processing
|
CpeDescription |
getCpeDescriptor()
Returns Cpe Descriptor
|
java.lang.String |
getDescriptor(java.util.List aList) |
java.net.URL |
getDescriptorURL(CpeCasProcessor aCasProcessorCfg)
Returns a descriptor path associated with Cas Processor
|
int |
getProcessingUnitThreadCount()
Returns number of processing threads (Processing Units)
|
ResourceManager |
getResourceManager()
Gets the ResourceManager that all components of this CPE should share.
|
ResourceSpecifier |
getSpecifier(java.net.URL aDescriptorUrl)
Instantiates a ResourceSpecifier from a given URL.
|
boolean |
isDefault() |
boolean |
isDefinitionInstanceOf(java.lang.Class aResourceClass,
ResourceSpecifier resourceSpecifier,
java.lang.String aDescriptor)
Check if a class has appropriate type
|
void |
parse()
Creates an object representation from default cpe descriptor.
|
void |
parse(java.io.InputStream aDescriptorStream)
Creates an object representation for configuration in a given stream
|
void |
parse(java.lang.String aDescriptor)
Creates an object representation for configuration in a given cpe descriptor file.
|
CasProcessor |
produceCasDataConsumer(java.lang.Class aResourceClass,
ResourceSpecifier aSpecifier,
java.util.Map aAdditionalParams)
Instantiates CasData Consumer from a given class.
|
public static final java.lang.String CPM_HOME
public java.util.HashMap casProcessorConfigMap
public CPEFactory(ResourceManager aResourceManager)
public CPEFactory(CpeDescription aDescriptor, ResourceManager aResourceManager) throws ResourceInitializationException
aDescriptor
- aResourceManager
- the resource manager that all components of this CPE will share If null, a new
ResourceManager will be created.ResourceInitializationException
public void parse(java.lang.String aDescriptor) throws java.lang.InstantiationException
aDescriptor
- -
path to the descriptorjava.lang.InstantiationException
public void parse(java.io.InputStream aDescriptorStream) throws java.lang.InstantiationException
aDescriptorStream
- -
stream containing cpe descriptionjava.lang.InstantiationException
public void parse()
aDescriptorStream
- -
stream containing cpe descriptionjava.lang.InstantiationException
public BaseCollectionReader getCollectionReader() throws ResourceConfigurationException
javax.naming.ConfigurationException
ResourceConfigurationException
public CasProcessor[] getCasProcessors() throws ResourceConfigurationException
ResourceConfigurationException
public boolean isDefinitionInstanceOf(java.lang.Class aResourceClass, ResourceSpecifier resourceSpecifier, java.lang.String aDescriptor) throws ResourceConfigurationException
aResourceClass
- -
class to checkresourceSpecifier
- -
specifier containing expected typeaDescriptor
- -
descriptor nameResourceConfigurationException
public CasProcessor produceCasDataConsumer(java.lang.Class aResourceClass, ResourceSpecifier aSpecifier, java.util.Map aAdditionalParams) throws ResourceInitializationException
aResourceClass
- -
CasDataConsumer classaSpecifier
- -
specifieraAdditionalParams
- -
parameters used to initialize CasDataConsumerResourceInitializationException
public java.net.URL getDescriptorURL(CpeCasProcessor aCasProcessorCfg) throws ResourceConfigurationException
aCasProcessorCfg
- -
Cas Processor configurationResourceConfigurationException
public ResourceSpecifier getSpecifier(java.net.URL aDescriptorUrl) throws java.lang.Exception
aDescriptorURL
- - URL of descriptorjava.lang.Exception
public CpeConfiguration getCPEConfig() throws java.lang.InstantiationException
java.lang.InstantiationException
public int getProcessingUnitThreadCount() throws ResourceConfigurationException
ResourceConfigurationException
public boolean isDefault()
public CpeDescription getCpeDescriptor()
public void addCasProcessor(CasProcessor aCasProcessor) throws ResourceConfigurationException
aCasProcessor
- -
CasProcessor to addResourceConfigurationException
public java.lang.String getDescriptor(java.util.List aList) throws ResourceConfigurationException
aList
- ResourceConfigurationException
public void addCollectionReader(BaseCollectionReader collectionReader)
collectionReader
- -
collection reader to use by the CPMpublic ResourceManager getResourceManager()
Copyright © 2014. All Rights Reserved.