You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by sc...@apache.org on 2016/11/12 18:26:09 UTC
svn commit: r1769397 [3/4] - in
/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl:
cpm/container/ cpm/container/deployer/socket/ cpm/engine/ cpm/utils/
cpm/vinci/ metadata/cpe/
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCasProcessorsImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCasProcessorsImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCasProcessorsImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCasProcessorsImpl.java Sat Nov 12 18:26:08 2016
@@ -40,23 +40,39 @@ import org.xml.sax.ContentHandler;
import org.xml.sax.SAXException;
import org.xml.sax.helpers.AttributesImpl;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeCasProcessorsImpl.
+ */
public class CpeCasProcessorsImpl extends MetaDataObject_impl implements CpeCasProcessors {
+
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = -5532660061637797550L;
+ /** The Constant DEFAULT_POOL_SIZE. */
private static final int DEFAULT_POOL_SIZE = 1;
+ /** The cas processors. */
private ArrayList casProcessors = new ArrayList();
+ /** The drop cas on exception. */
private boolean dropCasOnException;
+ /** The cas pool size. */
private int casPoolSize = DEFAULT_POOL_SIZE;
+ /** The processing unit thread count. */
private int processingUnitThreadCount = 1;
+ /** The input queue size. */
private int inputQueueSize;
+ /** The output queue size. */
private int outputQueueSize;
+ /**
+ * Instantiates a new cpe cas processors impl.
+ */
public CpeCasProcessorsImpl() {
super();
}
@@ -66,6 +82,7 @@ public class CpeCasProcessorsImpl extend
*
* @see org.apache.uima.collection.metadata.CpeCasProcessors#setOutputQueueSize(int)
*/
+ @Override
public void setOutputQueueSize(int aOutputQueueSize) throws CpeDescriptorException {
outputQueueSize = aOutputQueueSize;
}
@@ -75,6 +92,7 @@ public class CpeCasProcessorsImpl extend
*
* @see org.apache.uima.collection.metadata.CpeCasProcessors#getOutputQueueSize()
*/
+ @Override
public int getOutputQueueSize() {
return outputQueueSize;
}
@@ -84,6 +102,7 @@ public class CpeCasProcessorsImpl extend
*
* @see org.apache.uima.collection.metadata.CpeCasProcessors#setInputQueueSize(int)
*/
+ @Override
public void setInputQueueSize(int aInputQueueSize) throws CpeDescriptorException {
inputQueueSize = aInputQueueSize;
}
@@ -93,6 +112,7 @@ public class CpeCasProcessorsImpl extend
*
* @see org.apache.uima.collection.metadata.CpeCasProcessors#getInputQueueSize()
*/
+ @Override
public int getInputQueueSize() {
return inputQueueSize;
}
@@ -102,6 +122,7 @@ public class CpeCasProcessorsImpl extend
*
* @see org.apache.uima.collection.metadata.CpeCasProcessors#setConcurrentPUCount(int)
*/
+ @Override
public void setConcurrentPUCount(int aConcurrentPUCount) throws CpeDescriptorException {
processingUnitThreadCount = aConcurrentPUCount;
}
@@ -111,6 +132,7 @@ public class CpeCasProcessorsImpl extend
*
* @see org.apache.uima.collection.metadata.CpeCasProcessors#getConcurrentPUCount()
*/
+ @Override
public int getConcurrentPUCount() {
return processingUnitThreadCount;
}
@@ -121,6 +143,7 @@ public class CpeCasProcessorsImpl extend
* @see org.apache.uima.collection.metadata.CpeCasProcessors#addCpeCasProcessor(org.apache.uima.collection.metadata.CpeCasProcessor,
* int)
*/
+ @Override
public void addCpeCasProcessor(CpeCasProcessor aCasProcessor, int aInsertPosition)
throws CpeDescriptorException {
casProcessors.add(aInsertPosition, aCasProcessor);
@@ -132,6 +155,7 @@ public class CpeCasProcessorsImpl extend
* @see org.apache.uima.collection.metadata.CpeCasProcessors#addCpeCasProcessor(org.apache.uima.collection.metadata.CpeCasProcessor,
* int)
*/
+ @Override
public void addCpeCasProcessor(CpeCasProcessor aCasProcessor) throws CpeDescriptorException {
casProcessors.add(aCasProcessor);
}
@@ -141,6 +165,7 @@ public class CpeCasProcessorsImpl extend
*
* @see org.apache.uima.collection.metadata.CpeCasProcessors#getCpeCasProcessor(int)
*/
+ @Override
public CpeCasProcessor getCpeCasProcessor(int aPosition) throws CpeDescriptorException {
if (aPosition <= casProcessors.size()) {
return (CpeCasProcessor) casProcessors.get(aPosition);
@@ -156,12 +181,19 @@ public class CpeCasProcessorsImpl extend
*
* @see org.apache.uima.collection.metadata.CpeCasProcessors#getAllCpeCasProcessors()
*/
+ @Override
public CpeCasProcessor[] getAllCpeCasProcessors() throws CpeDescriptorException {
CpeCasProcessor[] processors = new CpeCasProcessor[casProcessors.size()];
casProcessors.toArray(processors);
return processors;
}
+ /**
+ * Sets the all cpe cas processors.
+ *
+ * @param aCpeProcessors the new all cpe cas processors
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
/*
* (non-Javadoc)
*
@@ -180,6 +212,7 @@ public class CpeCasProcessorsImpl extend
*
* @see org.apache.uima.collection.metadata.CpeCasProcessors#removeCpeCasProcessor(int)
*/
+ @Override
public void removeCpeCasProcessor(int aPosition) throws CpeDescriptorException {
if (aPosition <= casProcessors.size()) {
casProcessors.remove(aPosition);
@@ -192,7 +225,12 @@ public class CpeCasProcessorsImpl extend
}
/**
- * New API 01/06/2006
+ * New API 01/06/2006.
+ *
+ * @param aPosition the a position
+ * @param flag the flag
+ * @return the cpe cas processor[]
+ * @throws CpeDescriptorException the cpe descriptor exception
*/
public CpeCasProcessor[] removeCpeCasProcessor(int aPosition, boolean flag)
throws CpeDescriptorException {
@@ -212,6 +250,7 @@ public class CpeCasProcessorsImpl extend
*
* @see org.apache.uima.collection.metadata.CpeCasProcessors#removeAllCpeCasProcessors()
*/
+ @Override
public void removeAllCpeCasProcessors() throws CpeDescriptorException {
casProcessors.clear();
}
@@ -221,10 +260,17 @@ public class CpeCasProcessorsImpl extend
*
* @see org.apache.uima.collection.metadata.CpeCasProcessors#setOutputQueueSize(int)
*/
+ @Override
public void setPoolSize(int aPoolSize) throws CpeDescriptorException {
casPoolSize = aPoolSize;
}
+ /**
+ * Gets the pool size.
+ *
+ * @return the pool size
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
/*
* (non-Javadoc)
*
@@ -234,6 +280,12 @@ public class CpeCasProcessorsImpl extend
return casPoolSize;
}
+ /**
+ * Sets the drop cas on exception.
+ *
+ * @param aDropCasOnException the new drop cas on exception
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
/*
* (non-Javadoc)
*
@@ -248,16 +300,22 @@ public class CpeCasProcessorsImpl extend
*
* @see org.apache.uima.collection.metadata.CpeCasProcessors#setOutputQueueSize(int)
*/
+ @Override
public boolean getDropCasOnException() {
return dropCasOnException;
}
/**
* Overridden to read Cas Processor attributes.
- *
+ *
+ * @param aElement the a element
+ * @param aParser the a parser
+ * @param aOptions the a options
+ * @throws InvalidXMLException the invalid XML exception
* @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#buildFromXMLElement(org.w3c.dom.Element,
* org.apache.uima.util.XMLParser, org.apache.uima.util.XMLParser.ParsingOptions)
*/
+ @Override
public void buildFromXMLElement(Element aElement, XMLParser aParser, ParsingOptions aOptions)
throws InvalidXMLException {
try {
@@ -359,6 +417,10 @@ public class CpeCasProcessorsImpl extend
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#toXML(org.xml.sax.ContentHandler, boolean)
+ */
+ @Override
public void toXML(ContentHandler aContentHandler, boolean aWriteDefaultNamespaceAttribute)
throws SAXException {
XmlizationInfo inf = getXmlizationInfo();
@@ -388,9 +450,11 @@ public class CpeCasProcessorsImpl extend
/**
* Overridden to handle Cas Processor attributes.
- *
+ *
+ * @return the XML attributes
* @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXMLAttributes()
*/
+ @Override
protected AttributesImpl getXMLAttributes() {
AttributesImpl attrs = super.getXMLAttributes();
if (isDropCasOnException() == true) {
@@ -412,13 +476,22 @@ public class CpeCasProcessorsImpl extend
return attrs;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXmlizationInfo()
+ */
+ @Override
protected XmlizationInfo getXmlizationInfo() {
return XMLIZATION_INFO;
}
+ /** The Constant XMLIZATION_INFO. */
static final private XmlizationInfo XMLIZATION_INFO = new XmlizationInfo("casProcessors",
new PropertyXmlInfo[] { new PropertyXmlInfo("allCpeCasProcessors", null), });
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeCasProcessors#getCasPoolSize()
+ */
+ @Override
public int getCasPoolSize() {
// Indirection needed to handle the exception. xsdbeans based implementation of this API
// was throwing it, if there was a problem. With the current approach this exception never
@@ -431,6 +504,11 @@ public class CpeCasProcessorsImpl extend
return 1;
}
+ /**
+ * Checks if is drop cas on exception.
+ *
+ * @return true, if is drop cas on exception
+ */
public boolean isDropCasOnException() {
// Indirection needed to handle the exception. xsdbeans based implementation of this API
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCheckpointImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCheckpointImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCheckpointImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCheckpointImpl.java Sat Nov 12 18:26:08 2016
@@ -30,15 +30,27 @@ import org.apache.uima.util.XMLParser.Pa
import org.w3c.dom.Element;
import org.xml.sax.helpers.AttributesImpl;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeCheckpointImpl.
+ */
public class CpeCheckpointImpl extends MetaDataObject_impl implements CpeCheckpoint {
+
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = 9155094513948815121L;
+ /** The file. */
private String file;
+ /** The time. */
private String time;
+ /** The batch. */
private int batch;
+ /**
+ * Instantiates a new cpe checkpoint impl.
+ */
public CpeCheckpointImpl() {
}
@@ -47,6 +59,7 @@ public class CpeCheckpointImpl extends M
*
* @see org.apache.uima.collection.metadata.CpeCheckpoint#setFilePath(java.lang.String)
*/
+ @Override
public void setFilePath(String aCheckpointFilePath) throws CpeDescriptorException {
file = aCheckpointFilePath;
}
@@ -56,6 +69,7 @@ public class CpeCheckpointImpl extends M
*
* @see org.apache.uima.collection.metadata.CpeCheckpoint#getFilePath()
*/
+ @Override
public String getFilePath() {
return file;
}
@@ -65,10 +79,17 @@ public class CpeCheckpointImpl extends M
*
* @see org.apache.uima.collection.metadata.CpeCheckpoint#setFrequency(int, boolean)
*/
+ @Override
public void setFrequency(int aFrequency, boolean aTimeBased) {
time = String.valueOf(aFrequency) + "ms";
}
+ /**
+ * Convert 2 number.
+ *
+ * @param anObject the an object
+ * @return the int
+ */
private int convert2Number(Object anObject) {
int convertedTime = 1;
@@ -94,6 +115,7 @@ public class CpeCheckpointImpl extends M
*
* @see org.apache.uima.collection.metadata.CpeCheckpoint#getFrequency()
*/
+ @Override
public int getFrequency() {
return convert2Number(time);
}
@@ -103,6 +125,7 @@ public class CpeCheckpointImpl extends M
*
* @see org.apache.uima.collection.metadata.CpeCheckpoint#isTimeBased()
*/
+ @Override
public boolean isTimeBased() {
return true;
}
@@ -112,6 +135,7 @@ public class CpeCheckpointImpl extends M
*
* @see org.apache.uima.collection.metadata.CpeCheckpoint#setBatchSize(int)
*/
+ @Override
public void setBatchSize(int aBatchSize) {
batch = aBatchSize;
}
@@ -121,16 +145,22 @@ public class CpeCheckpointImpl extends M
*
* @see org.apache.uima.collection.metadata.CpeCheckpoint#getBatchSize()
*/
+ @Override
public int getBatchSize() {
return batch;
}
/**
* Overridden to read Checkpoint attributes.
- *
+ *
+ * @param aElement the a element
+ * @param aParser the a parser
+ * @param aOptions the a options
+ * @throws InvalidXMLException the invalid XML exception
* @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#buildFromXMLElement(org.w3c.dom.Element,
* org.apache.uima.util.XMLParser, org.apache.uima.util.XMLParser.ParsingOptions)
*/
+ @Override
public void buildFromXMLElement(Element aElement, XMLParser aParser, ParsingOptions aOptions)
throws InvalidXMLException {
setFile(aElement.getAttribute("file"));
@@ -144,9 +174,11 @@ public class CpeCheckpointImpl extends M
/**
* Overridden to handle Checkpoint attributes.
- *
+ *
+ * @return the XML attributes
* @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXMLAttributes()
*/
+ @Override
protected AttributesImpl getXMLAttributes() {
AttributesImpl attrs = super.getXMLAttributes();
attrs.addAttribute("", "batch", "batch", "CDATA", String.valueOf(getBatch()));
@@ -159,14 +191,23 @@ public class CpeCheckpointImpl extends M
return attrs;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXmlizationInfo()
+ */
+ @Override
protected XmlizationInfo getXmlizationInfo() {
return XMLIZATION_INFO;
}
+ /** The Constant XMLIZATION_INFO. */
static final private XmlizationInfo XMLIZATION_INFO = new XmlizationInfo("checkpoint",
new PropertyXmlInfo[0]);
- /** METHODS CALLED BY THE PARSER * */
+ /**
+ * METHODS CALLED BY THE PARSER *.
+ *
+ * @return the batch
+ */
/**
* @return the batch size
*/
@@ -175,6 +216,8 @@ public class CpeCheckpointImpl extends M
}
/**
+ * Gets the file.
+ *
* @return a file
*/
public String getFile() {
@@ -182,6 +225,8 @@ public class CpeCheckpointImpl extends M
}
/**
+ * Gets the time.
+ *
* @return a time
*/
public String getTime() {
@@ -189,21 +234,27 @@ public class CpeCheckpointImpl extends M
}
/**
- * @param i
+ * Sets the batch.
+ *
+ * @param i the new batch
*/
public void setBatch(int i) {
batch = i;
}
/**
- * @param string
+ * Sets the file.
+ *
+ * @param string the new file
*/
public void setFile(String string) {
file = string;
}
/**
- * @param i
+ * Sets the time.
+ *
+ * @param i the new time
*/
public void setTime(String i) {
time = i;
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCollectionReaderCasInitializerImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCollectionReaderCasInitializerImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCollectionReaderCasInitializerImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCollectionReaderCasInitializerImpl.java Sat Nov 12 18:26:08 2016
@@ -32,22 +32,34 @@ import org.apache.uima.resource.metadata
import org.apache.uima.resource.metadata.impl.PropertyXmlInfo;
import org.apache.uima.resource.metadata.impl.XmlizationInfo;
+// TODO: Auto-generated Javadoc
/**
+ * The Class CpeCollectionReaderCasInitializerImpl.
+ *
* @deprecated As of v2.0, CAS Initializers are deprecated.
*/
@Deprecated
public class CpeCollectionReaderCasInitializerImpl extends MetaDataObject_impl implements
CpeCollectionReaderCasInitializer {
+
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = -6284616239685904940L;
+ /** The descriptor. */
private CpeComponentDescriptor descriptor;
+ /** The configuration parameter settings. */
private ConfigurationParameterSettings configurationParameterSettings;
+ /** The cfps. */
private CasProcessorConfigurationParameterSettings cfps;
+ /** The sofa name mappings. */
private CpeSofaMappings sofaNameMappings;
+ /**
+ * Instantiates a new cpe collection reader cas initializer impl.
+ */
public CpeCollectionReaderCasInitializerImpl() {
}
@@ -56,6 +68,7 @@ public class CpeCollectionReaderCasIniti
*
* @see org.apache.uima.collection.metadata.CpeCollectionReaderCasInitializer#setDescriptorPath(java.lang.String)
*/
+ @Override
public void setDescriptor(CpeComponentDescriptor aDescriptor) {
descriptor = aDescriptor;
}
@@ -65,20 +78,28 @@ public class CpeCollectionReaderCasIniti
*
* @see org.apache.uima.collection.metadata.CpeCollectionReaderCasInitializer#getDescriptorPath()
*/
+ @Override
public CpeComponentDescriptor getDescriptor() {
return descriptor;
}
/**
* Returns configuration parameter settings for this CasInitializer.
+ *
+ * @return the configuration parameter settings
*/
+ @Override
public CasProcessorConfigurationParameterSettings getConfigurationParameterSettings() {
return cfps;
}
/**
* Sets configuration parameter settings for this CasInitializer.
+ *
+ * @param settings the new configuration parameter settings
+ * @throws CpeDescriptorException the cpe descriptor exception
*/
+ @Override
public void setConfigurationParameterSettings(CasProcessorConfigurationParameterSettings settings)
throws CpeDescriptorException {
cfps = settings;
@@ -101,6 +122,8 @@ public class CpeCollectionReaderCasIniti
}
/**
+ * Gets the parameter settings.
+ *
* @return the parameter settings
*/
public ConfigurationParameterSettings getParameterSettings() {
@@ -121,7 +144,9 @@ public class CpeCollectionReaderCasIniti
}
/**
- * @param settings
+ * Sets the parameter settings.
+ *
+ * @param settings the new parameter settings
*/
public void setParameterSettings(ConfigurationParameterSettings settings) {
configurationParameterSettings = settings;
@@ -131,10 +156,15 @@ public class CpeCollectionReaderCasIniti
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXmlizationInfo()
+ */
+ @Override
protected XmlizationInfo getXmlizationInfo() {
return XMLIZATION_INFO;
}
+ /** The Constant XMLIZATION_INFO. */
static final private XmlizationInfo XMLIZATION_INFO = new XmlizationInfo("casInitializer",
new PropertyXmlInfo[] { new PropertyXmlInfo("descriptor", null),
new PropertyXmlInfo("parameterSettings", null),
@@ -143,15 +173,21 @@ public class CpeCollectionReaderCasIniti
});
/**
+ * Gets the sofa name mappings.
+ *
* @return the sofa mappings
*/
+ @Override
public CpeSofaMappings getSofaNameMappings() {
return sofaNameMappings;
}
/**
- * @param mappings
+ * Sets the sofa name mappings.
+ *
+ * @param mappings the new sofa name mappings
*/
+ @Override
public void setSofaNameMappings(CpeSofaMappings mappings) {
sofaNameMappings = mappings;
}
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCollectionReaderImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCollectionReaderImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCollectionReaderImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCollectionReaderImpl.java Sat Nov 12 18:26:08 2016
@@ -29,13 +29,24 @@ import org.apache.uima.resource.metadata
import org.apache.uima.resource.metadata.impl.PropertyXmlInfo;
import org.apache.uima.resource.metadata.impl.XmlizationInfo;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeCollectionReaderImpl.
+ */
public class CpeCollectionReaderImpl extends MetaDataObject_impl implements CpeCollectionReader {
+
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = -7663775553359776495L;
+ /** The collection iterator. */
private CpeCollectionReaderIterator collectionIterator;
+ /** The cas initializer. */
private CpeCollectionReaderCasInitializer casInitializer;
+ /**
+ * Instantiates a new cpe collection reader impl.
+ */
public CpeCollectionReaderImpl() {
}
@@ -44,6 +55,7 @@ public class CpeCollectionReaderImpl ext
*
* @see org.apache.uima.collection.metadata.CpeCollectionReader#setCasInitializer(org.apache.uima.collection.metadata.CpeCollectionReaderCasInitializer)
*/
+ @Override
public void setCasInitializer(CpeCollectionReaderCasInitializer aCasInitializer)
throws CpeDescriptorException {
casInitializer = aCasInitializer;
@@ -54,6 +66,7 @@ public class CpeCollectionReaderImpl ext
*
* @see org.apache.uima.collection.metadata.CpeCollectionReader#getCasInitializer()
*/
+ @Override
public CpeCollectionReaderCasInitializer getCasInitializer() throws CpeDescriptorException {
return casInitializer;
}
@@ -63,6 +76,7 @@ public class CpeCollectionReaderImpl ext
*
* @see org.apache.uima.collection.metadata.CpeCollectionReader#removeCasInitializer()
*/
+ @Override
public void removeCasInitializer() {
casInitializer = null;
}
@@ -72,6 +86,7 @@ public class CpeCollectionReaderImpl ext
*
* @see org.apache.uima.collection.metadata.CpeCollectionReaderCasInitializer#setDescriptorPath(java.lang.String)
*/
+ @Override
public void setDescriptor(CpeComponentDescriptor aDescriptor) {
collectionIterator.setDescriptor(aDescriptor);
}
@@ -81,40 +96,60 @@ public class CpeCollectionReaderImpl ext
*
* @see org.apache.uima.collection.metadata.CpeCollectionReaderCasInitializer#getDescriptorPath()
*/
+ @Override
public CpeComponentDescriptor getDescriptor() {
return collectionIterator.getDescriptor();
}
/**
* Returns configuration parameter settings for this CollectionReader.
+ *
+ * @return the configuration parameter settings
*/
+ @Override
public CasProcessorConfigurationParameterSettings getConfigurationParameterSettings() {
return collectionIterator.getConfigurationParameterSettings();
}
/**
* Sets configuration parameter settings for this CollectionReader.
+ *
+ * @param aParams the new configuration parameter settings
+ * @throws CpeDescriptorException the cpe descriptor exception
*/
+ @Override
public void setConfigurationParameterSettings(CasProcessorConfigurationParameterSettings aParams)
throws CpeDescriptorException {
collectionIterator.setConfigurationParameterSettings(aParams);
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXmlizationInfo()
+ */
+ @Override
protected XmlizationInfo getXmlizationInfo() {
return XMLIZATION_INFO;
}
+ /** The Constant XMLIZATION_INFO. */
static final private XmlizationInfo XMLIZATION_INFO = new XmlizationInfo("collectionReader",
new PropertyXmlInfo[] { new PropertyXmlInfo("collectionIterator", null),
new PropertyXmlInfo("casInitializer", null), });
/**
- * @param iterator
+ * Sets the collection iterator.
+ *
+ * @param iterator the new collection iterator
*/
+ @Override
public void setCollectionIterator(CpeCollectionReaderIterator iterator) {
collectionIterator = iterator;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeCollectionReader#getCollectionIterator()
+ */
+ @Override
public CpeCollectionReaderIterator getCollectionIterator() {
return collectionIterator;
}
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCollectionReaderIteratorImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCollectionReaderIteratorImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCollectionReaderIteratorImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeCollectionReaderIteratorImpl.java Sat Nov 12 18:26:08 2016
@@ -31,36 +31,57 @@ import org.apache.uima.resource.metadata
import org.apache.uima.resource.metadata.impl.PropertyXmlInfo;
import org.apache.uima.resource.metadata.impl.XmlizationInfo;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeCollectionReaderIteratorImpl.
+ */
public class CpeCollectionReaderIteratorImpl extends MetaDataObject_impl implements
CpeCollectionReaderIterator {
+
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = -9208074797482603808L;
+ /** The descriptor. */
private CpeComponentDescriptor descriptor;
+ /** The configuration parameter settings. */
private CasProcessorConfigurationParameterSettings configurationParameterSettings;
+ /** The sofa name mappings. */
private CpeSofaMappings sofaNameMappings;
+ /** The config parameter settings. */
private ConfigurationParameterSettings configParameterSettings;
/**
+ * Gets the descriptor.
+ *
* @return the component descriptor
*/
+ @Override
public CpeComponentDescriptor getDescriptor() {
return descriptor;
}
/**
- * @param descriptor
+ * Sets the descriptor.
+ *
+ * @param descriptor the new descriptor
*/
+ @Override
public void setDescriptor(CpeComponentDescriptor descriptor) {
this.descriptor = descriptor;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXmlizationInfo()
+ */
+ @Override
protected XmlizationInfo getXmlizationInfo() {
return XMLIZATION_INFO;
}
+ /** The Constant XMLIZATION_INFO. */
static final private XmlizationInfo XMLIZATION_INFO = new XmlizationInfo("collectionIterator",
new PropertyXmlInfo[] { new PropertyXmlInfo("descriptor", null),
new PropertyXmlInfo("configParameterSettings", null),
@@ -69,17 +90,23 @@ public class CpeCollectionReaderIterator
});
/**
+ * Gets the configuration parameter settings.
+ *
* @return the parameter settings
*/
+ @Override
public CasProcessorConfigurationParameterSettings getConfigurationParameterSettings() {
return configurationParameterSettings;
}
/**
- * @param settings
+ * Sets the configuration parameter settings.
+ *
+ * @param settings the new configuration parameter settings
*/
+ @Override
public void setConfigurationParameterSettings(CasProcessorConfigurationParameterSettings settings) {
configurationParameterSettings = settings;
if (settings != null && settings.getParameterSettings() != null) {
@@ -99,6 +126,8 @@ public class CpeCollectionReaderIterator
}
/**
+ * Gets the config parameter settings.
+ *
* @return the parameter settings
*/
public ConfigurationParameterSettings getConfigParameterSettings() {
@@ -118,7 +147,9 @@ public class CpeCollectionReaderIterator
}
/**
- * @param settings
+ * Sets the config parameter settings.
+ *
+ * @param settings the new config parameter settings
*/
public void setConfigParameterSettings(ConfigurationParameterSettings settings) {
configParameterSettings = settings;
@@ -129,15 +160,21 @@ public class CpeCollectionReaderIterator
}
/**
+ * Gets the sofa name mappings.
+ *
* @return the sofa name mappings
*/
+ @Override
public CpeSofaMappings getSofaNameMappings() {
return sofaNameMappings;
}
/**
- * @param mappings
+ * Sets the sofa name mappings.
+ *
+ * @param mappings the new sofa name mappings
*/
+ @Override
public void setSofaNameMappings(CpeSofaMappings mappings) {
sofaNameMappings = mappings;
}
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeComponentDescriptorImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeComponentDescriptorImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeComponentDescriptorImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeComponentDescriptorImpl.java Sat Nov 12 18:26:08 2016
@@ -33,14 +33,25 @@ import org.apache.uima.resource.metadata
import org.apache.uima.resource.metadata.impl.XmlizationInfo;
import org.apache.uima.util.InvalidXMLException;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeComponentDescriptorImpl.
+ */
public class CpeComponentDescriptorImpl extends MetaDataObject_impl implements
CpeComponentDescriptor {
+
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = 1607312024379882416L;
+ /** The m include. */
private CpeInclude mInclude;
+ /** The m import. */
private Import mImport;
+ /**
+ * Instantiates a new cpe component descriptor impl.
+ */
public CpeComponentDescriptorImpl() {
}
@@ -49,6 +60,7 @@ public class CpeComponentDescriptorImpl
*
* @see org.apache.uima.collection.metadata.CpeComponentDescriptor#setInclude(org.apache.uima.collection.metadata.CpeInclude)
*/
+ @Override
public void setInclude(CpeInclude aInclude) {
mInclude = aInclude;
}
@@ -58,6 +70,7 @@ public class CpeComponentDescriptorImpl
*
* @see org.apache.uima.collection.metadata.CpeComponentDescriptor#getInclude()
*/
+ @Override
public CpeInclude getInclude() {
return mInclude;
}
@@ -67,6 +80,7 @@ public class CpeComponentDescriptorImpl
/* (non-Javadoc)
* @see org.apache.uima.collection.metadata.CpeComponentDescriptor#getImport()
*/
+ @Override
public Import getImport() {
return mImport;
}
@@ -74,13 +88,20 @@ public class CpeComponentDescriptorImpl
/* (non-Javadoc)
* @see org.apache.uima.collection.metadata.CpeComponentDescriptor#setImport(org.apache.uima.resource.metadata.Import)
*/
+ @Override
public void setImport(Import aImport) {
mImport = aImport;
}
/**
+ * Find absolute url.
+ *
+ * @param aResourceManager the a resource manager
+ * @return the url
+ * @throws ResourceConfigurationException the resource configuration exception
* @see CpeComponentDescriptor#findAbsoluteUrl(ResourceManager)
*/
+ @Override
public URL findAbsoluteUrl(ResourceManager aResourceManager) throws ResourceConfigurationException {
try {
if (mImport != null) {
@@ -113,10 +134,15 @@ public class CpeComponentDescriptorImpl
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXmlizationInfo()
+ */
+ @Override
protected XmlizationInfo getXmlizationInfo() {
return XMLIZATION_INFO;
}
+ /** The Constant XMLIZATION_INFO. */
static final private XmlizationInfo XMLIZATION_INFO = new XmlizationInfo("descriptor",
new PropertyXmlInfo[] {
new PropertyXmlInfo("include", null),
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeConfigurationImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeConfigurationImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeConfigurationImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeConfigurationImpl.java Sat Nov 12 18:26:08 2016
@@ -28,21 +28,36 @@ import org.apache.uima.resource.metadata
import org.apache.uima.resource.metadata.impl.PropertyXmlInfo;
import org.apache.uima.resource.metadata.impl.XmlizationInfo;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeConfigurationImpl.
+ */
public class CpeConfigurationImpl extends MetaDataObject_impl implements CpeConfiguration {
+
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = 1153815602567127240L;
+ /** The start at. */
private String startAt;
+ /** The num 2 process. */
private long num2Process;
+ /** The checkpoint. */
private CpeCheckpoint checkpoint;
+ /** The timer impl. */
private String timerImpl;
+ /** The deploy as. */
private String deployAs;
+ /** The output queue. */
private OutputQueue outputQueue;
+ /**
+ * Instantiates a new cpe configuration impl.
+ */
public CpeConfigurationImpl() {
}
@@ -51,6 +66,7 @@ public class CpeConfigurationImpl extend
*
* @see org.apache.uima.collection.metadata.CpeConfiguration#setDeployment(java.lang.String)
*/
+ @Override
public void setDeployment(String aDeploy) throws CpeDescriptorException {
deployAs = aDeploy;
}
@@ -60,6 +76,7 @@ public class CpeConfigurationImpl extend
*
* @see org.apache.uima.collection.metadata.CpeConfiguration#getDeployment()
*/
+ @Override
public String getDeployment() {
return deployAs;
}
@@ -69,6 +86,7 @@ public class CpeConfigurationImpl extend
*
* @see org.apache.uima.collection.metadata.CpeConfiguration#setNumToProcess(int)
*/
+ @Override
public void setNumToProcess(int aNumToProcess) throws CpeDescriptorException {
num2Process = aNumToProcess;
}
@@ -78,10 +96,15 @@ public class CpeConfigurationImpl extend
*
* @see org.apache.uima.collection.metadata.CpeConfiguration#getNumToProcess()
*/
+ @Override
public int getNumToProcess() {
return (int) num2Process;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeConfiguration#setStartingEntityId(java.lang.String)
+ */
+ @Override
public void setStartingEntityId(String aStartAt) {
startAt = aStartAt;
}
@@ -91,6 +114,7 @@ public class CpeConfigurationImpl extend
*
* @see org.apache.uima.collection.metadata.CpeConfiguration#getStartingEntityId()
*/
+ @Override
public String getStartingEntityId() {
return startAt;
}
@@ -100,6 +124,7 @@ public class CpeConfigurationImpl extend
*
* @see org.apache.uima.collection.metadata.CpeConfiguration#setCheckpoint(org.apache.uima.collection.metadata.CpeCheckpoint)
*/
+ @Override
public void setCheckpoint(CpeCheckpoint aCheckpoint) throws CpeDescriptorException {
checkpoint = aCheckpoint;
}
@@ -109,6 +134,7 @@ public class CpeConfigurationImpl extend
*
* @see org.apache.uima.collection.metadata.CpeConfiguration#getCheckpoint()
*/
+ @Override
public CpeCheckpoint getCheckpoint() {
return checkpoint;
}
@@ -118,6 +144,7 @@ public class CpeConfigurationImpl extend
*
* @see org.apache.uima.collection.metadata.CpeConfiguration#removeCheckpoint()
*/
+ @Override
public void removeCheckpoint() {
checkpoint = null;
}
@@ -127,6 +154,7 @@ public class CpeConfigurationImpl extend
*
* @see org.apache.uima.collection.metadata.CpeConfiguration#setCpeTimer(org.apache.uima.collection.metadata.CpeTimer)
*/
+ @Override
public void setCpeTimer(CpeTimer aTimer) {
timerImpl = aTimer.get();
}
@@ -136,6 +164,7 @@ public class CpeConfigurationImpl extend
*
* @see org.apache.uima.collection.metadata.CpeConfiguration#getCpeTimer()
*/
+ @Override
public CpeTimer getCpeTimer() {
return new CpeTimerImpl(timerImpl);
}
@@ -145,42 +174,68 @@ public class CpeConfigurationImpl extend
*
* @see org.apache.uima.collection.metadata.CpeConfiguration#removeCpeTimer()
*/
+ @Override
public void removeCpeTimer() {
timerImpl = "";
}
+ /**
+ * Gets the deploy as.
+ *
+ * @return the deploy as
+ */
public String getDeployAs() {
return deployAs;
}
+ /**
+ * Gets the num 2 process.
+ *
+ * @return the num 2 process
+ */
public long getNum2Process() {
return num2Process;
}
+ /**
+ * Gets the start at.
+ *
+ * @return the start at
+ */
public String getStartAt() {
return startAt;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeConfiguration#getTimerImpl()
+ */
+ @Override
public String getTimerImpl() {
return timerImpl;
}
/**
- * @param string
+ * Sets the deploy as.
+ *
+ * @param string the new deploy as
*/
public void setDeployAs(String string) {
deployAs = string;
}
/**
- * @param l
+ * Sets the num to process.
+ *
+ * @param l the new num to process
*/
public void setNumToProcess(long l) {
num2Process = l;
}
/**
- * @param aStartAt
+ * Sets the start at.
+ *
+ * @param aStartAt the new start at
*/
public void setStartAt(String aStartAt) {
@@ -188,16 +243,26 @@ public class CpeConfigurationImpl extend
}
/**
- * @param string
+ * Sets the timer impl.
+ *
+ * @param string the new timer impl
*/
public void setTimerImpl(String string) {
timerImpl = string;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeConfiguration#getOutputQueue()
+ */
+ @Override
public OutputQueue getOutputQueue() {
return outputQueue;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeConfiguration#getMaxTimeToWait()
+ */
+ @Override
public int getMaxTimeToWait() {
if (getOutputQueue() == null) {
return 0;
@@ -206,16 +271,23 @@ public class CpeConfigurationImpl extend
}
/**
- * @param queue
+ * Sets the output queue.
+ *
+ * @param queue the new output queue
*/
public void setOutputQueue(OutputQueue queue) {
outputQueue = queue;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXmlizationInfo()
+ */
+ @Override
protected XmlizationInfo getXmlizationInfo() {
return XMLIZATION_INFO;
}
+ /** The Constant XMLIZATION_INFO. */
static final private XmlizationInfo XMLIZATION_INFO = new XmlizationInfo("cpeConfig",
new PropertyXmlInfo[] { new PropertyXmlInfo("numToProcess"),
new PropertyXmlInfo("deployAs"), new PropertyXmlInfo("checkpoint", null),
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeDescriptionImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeDescriptionImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeDescriptionImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeDescriptionImpl.java Sat Nov 12 18:26:08 2016
@@ -38,22 +38,41 @@ import org.apache.uima.util.XMLParser;
import org.apache.uima.util.XMLParser.ParsingOptions;
import org.w3c.dom.Element;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeDescriptionImpl.
+ */
public class CpeDescriptionImpl extends MetaDataObject_impl implements CpeDescription {
+
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = -8068920415609241198L;
+ /** The collection reader. */
private CpeCollectionReader collectionReader;
+ /** The cas processors. */
private CpeCasProcessors casProcessors;
+ /** The cpe configuration. */
private CpeConfiguration cpeConfiguration;
+ /** The resource mgr config. */
private CpeResourceManagerConfiguration resourceMgrConfig;
+ /**
+ * Instantiates a new cpe description impl.
+ */
public CpeDescriptionImpl() {
super();
}
/**
+ * Instantiates a new cpe description impl.
+ *
+ * @param aInput the a input
+ * @throws InvalidXMLException the invalid XML exception
+ */
+ /*
* This is needed for XMLParser.parseCpeDesription() to work. Typically users should use
* CpeDescriptorFactory.produceDescriptor() instead. - APL
*/
@@ -96,11 +115,19 @@ public class CpeDescriptionImpl extends
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#addCollectionReader(org.apache.uima.collection.metadata.CpeCollectionReader)
+ */
+ @Override
public void addCollectionReader(CpeCollectionReader aCollectionReader)
throws CpeDescriptorException {
collectionReader = aCollectionReader;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#addCollectionReader(java.lang.String)
+ */
+ @Override
public CpeCollectionReader addCollectionReader(String aCollectionReaderPath)
throws CpeDescriptorException {
if (collectionReader == null) {
@@ -112,8 +139,14 @@ public class CpeDescriptionImpl extends
}
/**
+ * Adds the cas initializer.
+ *
+ * @param aInitializerDescriptorPath the a initializer descriptor path
+ * @return the cpe collection reader cas initializer
+ * @throws CpeDescriptorException the cpe descriptor exception
* @deprecated As of v2.0, CAS Initializers are deprecated.
*/
+ @Override
@Deprecated
public CpeCollectionReaderCasInitializer addCasInitializer(String aInitializerDescriptorPath)
throws CpeDescriptorException {
@@ -130,6 +163,10 @@ public CpeCollectionReaderCasInitializer
return collectionReader.getCasInitializer();
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#getAllCollectionCollectionReaders()
+ */
+ @Override
public CpeCollectionReader[] getAllCollectionCollectionReaders() throws CpeDescriptorException {
if (collectionReader == null) {
return new CpeCollectionReader[0];
@@ -139,6 +176,10 @@ public CpeCollectionReaderCasInitializer
return readers;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#setAllCollectionCollectionReaders(org.apache.uima.collection.metadata.CpeCollectionReader[])
+ */
+ @Override
public void setAllCollectionCollectionReaders(CpeCollectionReader[] areaders)
throws CpeDescriptorException {
if (areaders == null || areaders.length == 0) {
@@ -149,23 +190,41 @@ public CpeCollectionReaderCasInitializer
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#setResourceManagerConfiguration(java.lang.String)
+ */
+ @Override
public void setResourceManagerConfiguration(String aResMgrConfPagth) {
if (resourceMgrConfig != null) {
resourceMgrConfig.set(aResMgrConfPagth);
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#setCpeResourceManagerConfiguration(org.apache.uima.collection.metadata.CpeResourceManagerConfiguration)
+ */
+ @Override
public void setCpeResourceManagerConfiguration(CpeResourceManagerConfiguration aResMgrConfPagth) {
resourceMgrConfig = aResMgrConfPagth;
}
+ /**
+ * Gets the cpe resource manager configuration.
+ *
+ * @return the cpe resource manager configuration
+ */
public CpeResourceManagerConfiguration getCpeResourceManagerConfiguration() {
return resourceMgrConfig;
}
/**
- * @deprecated
+ * Sets the input queue size.
+ *
+ * @param aSize the new input queue size
+ * @throws CpeDescriptorException the cpe descriptor exception
+ * @deprecated
*/
+ @Override
@Deprecated
public void setInputQueueSize(int aSize) throws CpeDescriptorException {
if (casProcessors == null) {
@@ -174,6 +233,10 @@ public void setInputQueueSize(int aSize)
casProcessors.setInputQueueSize(aSize);
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#setProcessingUnitThreadCount(int)
+ */
+ @Override
public void setProcessingUnitThreadCount(int aSize) throws CpeDescriptorException {
if (casProcessors == null) {
casProcessors = CpeDescriptorFactory.produceCasProcessors();
@@ -182,8 +245,13 @@ public void setInputQueueSize(int aSize)
}
/**
- * @deprecated
+ * Sets the output queue size.
+ *
+ * @param aSize the new output queue size
+ * @throws CpeDescriptorException the cpe descriptor exception
+ * @deprecated
*/
+ @Override
@Deprecated
public void setOutputQueueSize(int aSize) throws CpeDescriptorException {
if (casProcessors == null) {
@@ -192,14 +260,26 @@ public void setOutputQueueSize(int aSize
casProcessors.setOutputQueueSize(aSize);
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#setCpeCasProcessors(org.apache.uima.collection.metadata.CpeCasProcessors)
+ */
+ @Override
public void setCpeCasProcessors(CpeCasProcessors aCasProcessors) {
casProcessors = aCasProcessors;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#getCpeCasProcessors()
+ */
+ @Override
public CpeCasProcessors getCpeCasProcessors() throws CpeDescriptorException {
return casProcessors;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#addCasProcessor(org.apache.uima.collection.metadata.CpeCasProcessor)
+ */
+ @Override
public void addCasProcessor(CpeCasProcessor aCasProcessor) throws CpeDescriptorException {
if (casProcessors == null) {
casProcessors = CpeDescriptorFactory.produceCasProcessors();
@@ -207,6 +287,10 @@ public void setOutputQueueSize(int aSize
casProcessors.addCpeCasProcessor(aCasProcessor);
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#addCasProcessor(int, org.apache.uima.collection.metadata.CpeCasProcessor)
+ */
+ @Override
public void addCasProcessor(int index, CpeCasProcessor aCasProcessor)
throws CpeDescriptorException {
@@ -217,22 +301,45 @@ public void setOutputQueueSize(int aSize
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#setCpeConfiguration(org.apache.uima.collection.metadata.CpeConfiguration)
+ */
+ @Override
public void setCpeConfiguration(CpeConfiguration aConfiguration) {
cpeConfiguration = aConfiguration;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#getCpeConfiguration()
+ */
+ @Override
public CpeConfiguration getCpeConfiguration() throws CpeDescriptorException {
return cpeConfiguration;
}
+ /**
+ * Sets the cpe config.
+ *
+ * @param aConfiguration the new cpe config
+ */
public void setCpeConfig(CpeConfiguration aConfiguration) {
cpeConfiguration = aConfiguration;
}
+ /**
+ * Gets the cpe config.
+ *
+ * @return the cpe config
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
public CpeConfiguration getCpeConfig() throws CpeDescriptorException {
return cpeConfiguration;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#setCheckpoint(java.lang.String, int)
+ */
+ @Override
public void setCheckpoint(String aCheckpointFile, int aFrequency) {
if (cpeConfiguration != null) {
try {
@@ -244,6 +351,10 @@ public void setOutputQueueSize(int aSize
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#setDeployment(java.lang.String)
+ */
+ @Override
public void setDeployment(String aDeployMode) {
if (cpeConfiguration != null) {
try {
@@ -254,6 +365,10 @@ public void setOutputQueueSize(int aSize
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#setNumToProcess(long)
+ */
+ @Override
public void setNumToProcess(long aEntityCount) {
if (cpeConfiguration != null) {
try {
@@ -264,6 +379,10 @@ public void setOutputQueueSize(int aSize
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#setStartingEntityId(java.lang.String)
+ */
+ @Override
public void setStartingEntityId(String aStartEntityId) {
if (cpeConfiguration != null) {
try {
@@ -274,6 +393,10 @@ public void setOutputQueueSize(int aSize
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#setTimer(java.lang.String)
+ */
+ @Override
public void setTimer(String aTimerClass) {
if (cpeConfiguration != null) {
try {
@@ -284,6 +407,10 @@ public void setOutputQueueSize(int aSize
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeDescription#getResourceManagerConfiguration()
+ */
+ @Override
public CpeResourceManagerConfiguration getResourceManagerConfiguration() {
return resourceMgrConfig;
}
@@ -295,6 +422,7 @@ public void setOutputQueueSize(int aSize
* org.apache.uima.util.XMLParser, org.apache.uima.util.XMLParser.ParsingOptions,
* java.util.List)
*/
+ @Override
protected void readUnknownPropertyValueFromXMLElement(Element aElement, XMLParser aParser,
ParsingOptions aOptions, List aKnownPropertyNames) throws InvalidXMLException {
if (aElement.getNodeName().equals("resourceManagerConfiguration")) {
@@ -307,10 +435,15 @@ public void setOutputQueueSize(int aSize
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXmlizationInfo()
+ */
+ @Override
protected XmlizationInfo getXmlizationInfo() {
return XMLIZATION_INFO;
}
+ /** The Constant XMLIZATION_INFO. */
static final private XmlizationInfo XMLIZATION_INFO = new XmlizationInfo("cpeDescription",
new PropertyXmlInfo[] { new PropertyXmlInfo("allCollectionCollectionReaders", null),
new PropertyXmlInfo("cpeCasProcessors", null),
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeDescriptorFactory.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeDescriptorFactory.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeDescriptorFactory.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeDescriptorFactory.java Sat Nov 12 18:26:08 2016
@@ -56,6 +56,7 @@ import org.apache.uima.collection.metada
import org.apache.uima.util.InvalidXMLException;
import org.apache.uima.util.XMLInputSource;
+// TODO: Auto-generated Javadoc
/**
* Factory class for creating CpeDescriptors and their constituent objects.
*
@@ -63,6 +64,9 @@ import org.apache.uima.util.XMLInputSour
*/
public class CpeDescriptorFactory {
+ /**
+ * Instantiates a new cpe descriptor factory.
+ */
public CpeDescriptorFactory() {
}
@@ -133,7 +137,8 @@ public class CpeDescriptorFactory {
}
/**
- *
+ * Produce collection reader.
+ *
* @param aCollectionReaderDescriptorPath a path to the collection reader descriptor
* @param aDescriptor the descriptor to associate the collection reader with
* @return the CPE Collection Reader
@@ -154,6 +159,13 @@ public class CpeDescriptorFactory {
return colR[0];
}
+ /**
+ * Produce collection reader.
+ *
+ * @param aCollectionReaderDescriptorPath the a collection reader descriptor path
+ * @return the cpe collection reader
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
public static CpeCollectionReader produceCollectionReader(String aCollectionReaderDescriptorPath)
throws CpeDescriptorException {
CpeCollectionReader colR = produceCollectionReader();
@@ -161,12 +173,25 @@ public class CpeDescriptorFactory {
return colR;
}
+ /**
+ * Produce collection reader.
+ *
+ * @return the cpe collection reader
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
public static CpeCollectionReader produceCollectionReader() throws CpeDescriptorException {
CpeCollectionReader colR = new CpeCollectionReaderImpl();
colR.setCollectionIterator(produceCollectionReaderIterator(""));
return colR;
}
+ /**
+ * Produce collection reader iterator.
+ *
+ * @param aPath the a path
+ * @return the cpe collection reader iterator
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
public static CpeCollectionReaderIterator produceCollectionReaderIterator(String aPath)
throws CpeDescriptorException {
CpeCollectionReaderIterator iterator = new CpeCollectionReaderIteratorImpl();
@@ -175,12 +200,12 @@ public class CpeDescriptorFactory {
}
/**
- *
+ * Produce collection reader cas initializer.
+ *
* @param aPath don't use
- * @param aDescriptor don't use
- * @return a CPE Collection Reader CAS Initializer
+ * @param aDescriptor don't use
+ * @return a CPE Collection Reader CAS Initializer
* @throws CpeDescriptorException passed thru
- *
* @deprecated As of v2.0, CAS Initializers are deprecated.
*/
@Deprecated
@@ -195,7 +220,8 @@ public static CpeCollectionReaderCasInit
}
/**
- *
+ * Produce collection reader cas initializer.
+ *
* @param aInitializerDescriptorPath path to the initializer descriptor
* @return CPE Collection Reader CAS Initializer
* @deprecated As of v2.0, CAS Initializers are deprecated.
@@ -212,7 +238,8 @@ protected static CpeCollectionReaderCasI
}
/**
- *
+ * Produce component descriptor.
+ *
* @param aPath The path to the the CPE component Descriptor
* @return the CPE Component Description
*/
@@ -226,8 +253,9 @@ protected static CpeCollectionReaderCasI
}
/**
- *
- * @param aDescriptor CPE descriptor to use
+ * Produce cpe configuration.
+ *
+ * @param aDescriptor CPE descriptor to use
* @return the Cpe Configuration
* @throws CpeDescriptorException if it fails
*/
@@ -241,29 +269,56 @@ protected static CpeCollectionReaderCasI
return config;
}
+ /**
+ * Produce cpe configuration.
+ *
+ * @return the cpe configuration
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
public static CpeConfiguration produceCpeConfiguration() throws CpeDescriptorException {
return new CpeConfigurationImpl();
}
+ /**
+ * Produce runtime env param.
+ *
+ * @return the cas processor runtime env param
+ */
public static CasProcessorRuntimeEnvParam produceRuntimeEnvParam() {
return new CasProcessorRuntimeEnvParamImpl();
}
+ /**
+ * Produce deploy params.
+ *
+ * @return the cas processor deployment params
+ */
public static CasProcessorDeploymentParams produceDeployParams() {
return new CasProcessorDeploymentParamsImpl();
}
+ /**
+ * Produce deploy param.
+ *
+ * @return the cas processor deployment param
+ */
public static CasProcessorDeploymentParam produceDeployParam() {
return new CasProcessorDeploymentParamImpl();
}
+ /**
+ * Produce component descriptor include.
+ *
+ * @return the cpe include
+ */
public static CpeInclude produceComponentDescriptorInclude() {
return new CpeIncludeImpl();
}
/**
- *
+ * Produce cas processors.
+ *
* @param aDescriptor to use to produce the CPE CAS Processors
* @return Cpe CAS Processors
* @throws CpeDescriptorException if an error occurs
@@ -278,17 +333,24 @@ protected static CpeCollectionReaderCasI
return processors;
}
+ /**
+ * Produce cas processors.
+ *
+ * @return the cpe cas processors
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
public static CpeCasProcessors produceCasProcessors() throws CpeDescriptorException {
return new CpeCasProcessorsImpl();
}
/**
- *
+ * Produce cas processors.
+ *
* @param aInputQSize the input queue size
* @param aOutputQSize the output queue size
* @param aPuCount the number of processing units
* @param aDescriptor the CPE descriptor
- * @return CPE CAS Processors
+ * @return CPE CAS Processors
* @throws CpeDescriptorException if an error occurs
*/
public static CpeCasProcessors produceCasProcessors(int aInputQSize, int aOutputQSize,
@@ -304,6 +366,12 @@ protected static CpeCollectionReaderCasI
return processors;
}
+ /**
+ * Produce cas processor.
+ *
+ * @param aName the a name
+ * @return the cpe integrated cas processor
+ */
// Default deployment=integrated
public static CpeIntegratedCasProcessor produceCasProcessor(String aName) {
CpeIntegratedCasProcessor processor = new CpeIntegratedCasProcessorImpl();
@@ -316,7 +384,8 @@ protected static CpeCollectionReaderCasI
}
/**
- *
+ * Produce local cas processor.
+ *
* @param aName the processor name
* @param aSoFa the processor SofA
* @return CPE Local CAS Processor
@@ -331,9 +400,10 @@ protected static CpeCollectionReaderCasI
}
/**
- *
+ * Produce remote cas processor.
+ *
* @param aName the processor name
- * @return CPE Remote CAS Processor
+ * @return CPE Remote CAS Processor
* @throws CpeDescriptorException if an error occurs
*/
public static CpeRemoteCasProcessor produceRemoteCasProcessor(String aName)
@@ -343,10 +413,24 @@ protected static CpeCollectionReaderCasI
return processor;
}
+ /**
+ * Produce cpe timer.
+ *
+ * @param aTimerClass the a timer class
+ * @return the cpe timer
+ */
public static CpeTimer produceCpeTimer(String aTimerClass) {
return new CpeTimerImpl(aTimerClass);
}
+ /**
+ * Produce resource manager configuration.
+ *
+ * @param aResourceMgrConfigurationPath the a resource mgr configuration path
+ * @param aDescriptor the a descriptor
+ * @return the cpe resource manager configuration
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
public static CpeResourceManagerConfiguration produceResourceManagerConfiguration(
String aResourceMgrConfigurationPath, CpeDescription aDescriptor)
throws CpeDescriptorException {
@@ -358,6 +442,13 @@ protected static CpeCollectionReaderCasI
return resMgr;
}
+ /**
+ * Produce resource manager configuration.
+ *
+ * @param aResourceMgrConfigurationPath the a resource mgr configuration path
+ * @return the cpe resource manager configuration
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
public static CpeResourceManagerConfiguration produceResourceManagerConfiguration(
String aResourceMgrConfigurationPath) throws CpeDescriptorException {
CpeResourceManagerConfiguration resMgr = new CpeResourceManagerConfigurationImpl();
@@ -365,20 +456,36 @@ protected static CpeCollectionReaderCasI
return resMgr;
}
+ /**
+ * Produce cas processor timeout.
+ *
+ * @return the cas processor timeout
+ */
public static CasProcessorTimeout produceCasProcessorTimeout() {
return new CasProcessorTimeoutImpl();
}
+ /**
+ * Produce cas processor max restarts.
+ *
+ * @return the cas processor max restarts
+ */
public static CasProcessorMaxRestarts produceCasProcessorMaxRestarts() {
return new CasProcessorMaxRestartsImpl();
}
+ /**
+ * Produce cas processor error rate threshold.
+ *
+ * @return the cas processor error rate threshold
+ */
public static CasProcessorErrorRateThreshold produceCasProcessorErrorRateThreshold() {
return new CasProcessorErrorRateThresholdImpl();
}
/**
- *
+ * Produce cas processor filter.
+ *
* @param aFilter the filter string
* @return a CAS Processor Filter
*/
@@ -388,42 +495,92 @@ protected static CpeCollectionReaderCasI
return filter;
}
+ /**
+ * Produce cas processor error handling.
+ *
+ * @return the cas processor error handling
+ */
public static CasProcessorErrorHandling produceCasProcessorErrorHandling() {
return new CasProcessorErrorHandlingImpl();
}
+ /**
+ * Produce cpe checkpoint.
+ *
+ * @return the cpe checkpoint
+ */
public static CpeCheckpoint produceCpeCheckpoint() {
return new CpeCheckpointImpl();
}
+ /**
+ * Produce cas processor deployment params.
+ *
+ * @return the cas processor deployment params
+ */
public static CasProcessorDeploymentParams produceCasProcessorDeploymentParams() {
return new CasProcessorDeploymentParamsImpl();
}
+ /**
+ * Produce cas processor exec arg.
+ *
+ * @return the cas processor exec arg
+ */
public static CasProcessorExecArg produceCasProcessorExecArg() {
return new CasProcessorExecArgImpl();
}
+ /**
+ * Produce cas processor executable.
+ *
+ * @return the cas processor executable
+ */
public static CasProcessorExecutable produceCasProcessorExecutable() {
return new CasProcessorExecutableImpl();
}
+ /**
+ * Produce run in seperate process.
+ *
+ * @return the cas processor run in seperate process
+ */
public static CasProcessorRunInSeperateProcess produceRunInSeperateProcess() {
return new CasProcessorRunInSeperateProcessImpl();
}
+ /**
+ * Produce cas processor configuration parameter settings.
+ *
+ * @return the cas processor configuration parameter settings
+ */
public static CasProcessorConfigurationParameterSettings produceCasProcessorConfigurationParameterSettings() {
return new CasProcessorConfigurationParameterSettingsImpl();
}
+ /**
+ * Produce name value pair.
+ *
+ * @return the name value pair
+ */
public static NameValuePair produceNameValuePair() {
return new NameValuePairImpl();
}
+ /**
+ * Produce sofa mapping.
+ *
+ * @return the cpe sofa mapping
+ */
public static CpeSofaMapping produceSofaMapping() {
return new CpeSofaMappingImpl();
}
+ /**
+ * Produce sofa mappings.
+ *
+ * @return the cpe sofa mappings
+ */
public static CpeSofaMappings produceSofaMappings() {
return new CpeSofaMappingsImpl();
}
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeIncludeImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeIncludeImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeIncludeImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeIncludeImpl.java Sat Nov 12 18:26:08 2016
@@ -29,11 +29,21 @@ import org.apache.uima.util.XMLParser.Pa
import org.w3c.dom.Element;
import org.xml.sax.helpers.AttributesImpl;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeIncludeImpl.
+ */
public class CpeIncludeImpl extends MetaDataObject_impl implements CpeInclude {
+
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = 5694100109656286384L;
+ /** The href. */
private String href;
+ /**
+ * Instantiates a new cpe include impl.
+ */
public CpeIncludeImpl() {
}
@@ -42,6 +52,7 @@ public class CpeIncludeImpl extends Meta
*
* @see org.apache.uima.collection.metadata.CpeInclude#set(java.lang.String)
*/
+ @Override
public void set(String aPath) {
href = aPath;
}
@@ -51,16 +62,22 @@ public class CpeIncludeImpl extends Meta
*
* @see org.apache.uima.collection.metadata.CpeInclude#get()
*/
+ @Override
public String get() {
return href;
}
/**
* Overridden to read "href" attribute.
- *
+ *
+ * @param aElement the a element
+ * @param aParser the a parser
+ * @param aOptions the a options
+ * @throws InvalidXMLException the invalid XML exception
* @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#buildFromXMLElement(org.w3c.dom.Element,
* org.apache.uima.util.XMLParser, org.apache.uima.util.XMLParser.ParsingOptions)
*/
+ @Override
public void buildFromXMLElement(Element aElement, XMLParser aParser, ParsingOptions aOptions)
throws InvalidXMLException {
setHref(aElement.getAttribute("href"));
@@ -69,29 +86,43 @@ public class CpeIncludeImpl extends Meta
/**
* Overridden to handle "href" attribute.
- *
+ *
+ * @return the XML attributes
* @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXMLAttributes()
*/
+ @Override
protected AttributesImpl getXMLAttributes() {
AttributesImpl attrs = super.getXMLAttributes();
attrs.addAttribute("", "href", "href", "CDATA", getHref());
return attrs;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXmlizationInfo()
+ */
+ @Override
protected XmlizationInfo getXmlizationInfo() {
return XMLIZATION_INFO;
}
+ /** The Constant XMLIZATION_INFO. */
static final private XmlizationInfo XMLIZATION_INFO = new XmlizationInfo("include",
new PropertyXmlInfo[0]);
- /** METHODS CALLED BY THE PARSER * */
+ /**
+ * Gets the href.
+ *
+ * @return the href
+ */
+ /* METHODS CALLED BY THE PARSER * */
public String getHref() {
return href;
}
/**
- * @param string
+ * Sets the href.
+ *
+ * @param string the new href
*/
public void setHref(String string) {
href = string;
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeIntegratedCasProcessorImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeIntegratedCasProcessorImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeIntegratedCasProcessorImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeIntegratedCasProcessorImpl.java Sat Nov 12 18:26:08 2016
@@ -22,10 +22,19 @@ package org.apache.uima.collection.impl.
import org.apache.uima.collection.metadata.CasProcessorDeploymentParams;
import org.apache.uima.collection.metadata.CpeIntegratedCasProcessor;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeIntegratedCasProcessorImpl.
+ */
public class CpeIntegratedCasProcessorImpl extends CasProcessorCpeObject implements
CpeIntegratedCasProcessor {
+
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = 6076012896926381047L;
+ /**
+ * Instantiates a new cpe integrated cas processor impl.
+ */
public CpeIntegratedCasProcessorImpl()
{
@@ -39,6 +48,10 @@ public class CpeIntegratedCasProcessorIm
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.impl.metadata.cpe.CasProcessorCpeObject#addDefaults()
+ */
+ @Override
protected void addDefaults() {
try {
CasProcessorDeploymentParams deployParams = CpeDescriptorFactory.produceDeployParams();
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeLocalCasProcessorImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeLocalCasProcessorImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeLocalCasProcessorImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeLocalCasProcessorImpl.java Sat Nov 12 18:26:08 2016
@@ -31,10 +31,18 @@ import org.apache.uima.collection.metada
import org.apache.uima.collection.metadata.CpeLocalCasProcessor;
import org.apache.uima.collection.metadata.NameValuePair;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeLocalCasProcessorImpl.
+ */
public class CpeLocalCasProcessorImpl extends CasProcessorCpeObject implements CpeLocalCasProcessor {
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = -2239520502855587544L;
+ /**
+ * Instantiates a new cpe local cas processor impl.
+ */
public CpeLocalCasProcessorImpl() {
super();
try {
@@ -46,6 +54,11 @@ public class CpeLocalCasProcessorImpl ex
}
+ /**
+ * Instantiates a new cpe local cas processor impl.
+ *
+ * @param initializeWithDefaultValues the initialize with default values
+ */
public CpeLocalCasProcessorImpl(boolean initializeWithDefaultValues) {
super();
try {
@@ -59,6 +72,13 @@ public class CpeLocalCasProcessorImpl ex
}
+ /**
+ * Instantiates a new cpe local cas processor impl.
+ *
+ * @param aName the a name
+ * @param aSoFa the a so fa
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
protected CpeLocalCasProcessorImpl(String aName, String aSoFa) throws CpeDescriptorException {
super();
try {
@@ -72,6 +92,12 @@ public class CpeLocalCasProcessorImpl ex
}
}
+ /**
+ * Gets the base run in seperate process.
+ *
+ * @return the base run in seperate process
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
private CasProcessorRunInSeperateProcess getBaseRunInSeperateProcess()
throws CpeDescriptorException {
CasProcessorRunInSeperateProcess sepProcess = getRunInSeperateProcess();
@@ -85,6 +111,10 @@ public class CpeLocalCasProcessorImpl ex
return sepProcess;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeLocalCasProcessor#addExecArg(java.lang.String)
+ */
+ @Override
public void addExecArg(String aArgValue) throws CpeDescriptorException {
CasProcessorRunInSeperateProcess sepProcess = getBaseRunInSeperateProcess();
CasProcessorExecutable exe = sepProcess.getExecutable();
@@ -93,6 +123,12 @@ public class CpeLocalCasProcessorImpl ex
exe.addCasProcessorExecArg(execArg);
}
+ /**
+ * Removes the exec arg.
+ *
+ * @param aIndex the a index
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
public void removeExecArg(int aIndex) throws CpeDescriptorException {
CasProcessorRunInSeperateProcess rip = getRunInSeparateProcess();
if (rip != null) {
@@ -103,6 +139,12 @@ public class CpeLocalCasProcessorImpl ex
}
}
+ /**
+ * Gets the exec args.
+ *
+ * @return the exec args
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
public List getExecArgs() throws CpeDescriptorException {
ArrayList list = new ArrayList();
CasProcessorRunInSeperateProcess rip = getRunInSeparateProcess();
@@ -119,6 +161,10 @@ public class CpeLocalCasProcessorImpl ex
return list;
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.impl.metadata.cpe.CasProcessorCpeObject#addDefaults()
+ */
+ @Override
protected void addDefaults() throws CpeDescriptorException {
if (getRunInSeperateProcess() == null) {
CasProcessorRunInSeperateProcess sepProcess = CpeDescriptorFactory
@@ -153,6 +199,7 @@ public class CpeLocalCasProcessorImpl ex
*
* @see org.apache.uima.collection.metadata.CpeLocalCasProcessor#isJava()
*/
+ @Override
public boolean isJava() throws CpeDescriptorException {
CasProcessorRunInSeperateProcess rip = getRunInSeparateProcess();
if (rip != null) {
@@ -165,10 +212,14 @@ public class CpeLocalCasProcessorImpl ex
}
/**
- *
* Adds a new env key to the list of env keys. If a kay with a given key name exists the new key
* value replaces the old.
+ *
+ * @param aEnvKeyName the a env key name
+ * @param aEnvKeyValue the a env key value
+ * @throws CpeDescriptorException the cpe descriptor exception
*/
+ @Override
public void addExecEnv(String aEnvKeyName, String aEnvKeyValue) throws CpeDescriptorException {
CasProcessorRunInSeperateProcess rip = getRunInSeparateProcess();
if (rip != null) {
@@ -196,6 +247,12 @@ public class CpeLocalCasProcessorImpl ex
// }
}
+ /**
+ * Gets the exec env.
+ *
+ * @return the exec env
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
public List getExecEnv() throws CpeDescriptorException {
CasProcessorRunInSeperateProcess rip = getRunInSeparateProcess();
if (rip != null) {
@@ -207,6 +264,12 @@ public class CpeLocalCasProcessorImpl ex
return new ArrayList(); // empty list
}
+ /**
+ * Removes the exec env.
+ *
+ * @param aIndex the a index
+ * @throws CpeDescriptorException the cpe descriptor exception
+ */
public void removeExecEnv(int aIndex) throws CpeDescriptorException {
CasProcessorRunInSeperateProcess rip = getRunInSeparateProcess();
if (rip != null) {
@@ -220,6 +283,10 @@ public class CpeLocalCasProcessorImpl ex
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeLocalCasProcessor#setExecutable(java.lang.String)
+ */
+ @Override
public void setExecutable(String aCasProcessorExecutable) throws CpeDescriptorException {
CasProcessorRunInSeperateProcess rip = getRunInSeparateProcess();
if (rip != null) {
@@ -230,6 +297,10 @@ public class CpeLocalCasProcessorImpl ex
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeLocalCasProcessor#getExecutable()
+ */
+ @Override
public String getExecutable() throws CpeDescriptorException {
CasProcessorRunInSeperateProcess rip = getRunInSeparateProcess();
if (rip != null) {
@@ -246,6 +317,7 @@ public class CpeLocalCasProcessorImpl ex
*
* @see org.apache.uima.collection.metadata.CpeLocalCasProcessor#setIsJava(boolean)
*/
+ @Override
public void setIsJava(boolean aJava) throws CpeDescriptorException {
CasProcessorRunInSeperateProcess rip = getRunInSeparateProcess();
if (rip != null) {
@@ -257,11 +329,19 @@ public class CpeLocalCasProcessorImpl ex
}
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeLocalCasProcessor#setRunInSeperateProcess(org.apache.uima.collection.metadata.CasProcessorRunInSeperateProcess)
+ */
+ @Override
public void setRunInSeperateProcess(CasProcessorRunInSeperateProcess aSepProcess)
throws CpeDescriptorException {
super.setRunInSeparateProcess(aSepProcess);
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.metadata.CpeLocalCasProcessor#getRunInSeperateProcess()
+ */
+ @Override
public CasProcessorRunInSeperateProcess getRunInSeperateProcess() throws CpeDescriptorException {
return super.getRunInSeparateProcess();
}
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeObject.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeObject.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeObject.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeObject.java Sat Nov 12 18:26:08 2016
@@ -19,17 +19,38 @@
package org.apache.uima.collection.impl.metadata.cpe;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeObject.
+ */
public class CpeObject {
+
+ /** The internal object. */
private Object internalObject = null;
+ /**
+ * Instantiates a new cpe object.
+ *
+ * @param aObject the a object
+ */
protected CpeObject(Object aObject) {
internalObject = aObject;
}
+ /**
+ * Sets the.
+ *
+ * @param aObject the a object
+ */
protected void set(Object aObject) {
internalObject = aObject;
}
+ /**
+ * Gets the internal object.
+ *
+ * @return the internal object
+ */
public Object getInternalObject() {
return internalObject;
}
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeRemoteCasProcessorImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeRemoteCasProcessorImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeRemoteCasProcessorImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeRemoteCasProcessorImpl.java Sat Nov 12 18:26:08 2016
@@ -22,10 +22,19 @@ package org.apache.uima.collection.impl.
import org.apache.uima.collection.metadata.CasProcessorDeploymentParams;
import org.apache.uima.collection.metadata.CpeRemoteCasProcessor;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeRemoteCasProcessorImpl.
+ */
public class CpeRemoteCasProcessorImpl extends CasProcessorCpeObject implements
CpeRemoteCasProcessor {
+
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = -1290194910813284905L;
+ /**
+ * Instantiates a new cpe remote cas processor impl.
+ */
public CpeRemoteCasProcessorImpl() {
super();
try {
@@ -37,6 +46,10 @@ public class CpeRemoteCasProcessorImpl e
}
+ /* (non-Javadoc)
+ * @see org.apache.uima.collection.impl.metadata.cpe.CasProcessorCpeObject#addDefaults()
+ */
+ @Override
protected void addDefaults() {
try {
if (super.getDeploymentParams() == null) {
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeResourceManagerConfigurationImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeResourceManagerConfigurationImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeResourceManagerConfigurationImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeResourceManagerConfigurationImpl.java Sat Nov 12 18:26:08 2016
@@ -29,12 +29,22 @@ import org.apache.uima.util.XMLParser.Pa
import org.w3c.dom.Element;
import org.xml.sax.helpers.AttributesImpl;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeResourceManagerConfigurationImpl.
+ */
public class CpeResourceManagerConfigurationImpl extends MetaDataObject_impl implements
CpeResourceManagerConfiguration {
+
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = -8905321767282361433L;
+ /** The href. */
private String href;
+ /**
+ * Instantiates a new cpe resource manager configuration impl.
+ */
public CpeResourceManagerConfigurationImpl() {
}
@@ -43,6 +53,7 @@ public class CpeResourceManagerConfigura
*
* @see org.apache.uima.collection.metadata.CpeResourceManagerConfiguration#set(java.lang.String)
*/
+ @Override
public void set(String aPath) {
setHref(aPath);
}
@@ -52,16 +63,22 @@ public class CpeResourceManagerConfigura
*
* @see org.apache.uima.collection.metadata.CpeResourceManagerConfiguration#get()
*/
+ @Override
public String get() {
return getHref();
}
/**
* Overridden to read "href" attributes.
- *
+ *
+ * @param aElement the a element
+ * @param aParser the a parser
+ * @param aOptions the a options
+ * @throws InvalidXMLException the invalid XML exception
* @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#buildFromXMLElement(org.w3c.dom.Element,
* org.apache.uima.util.XMLParser, org.apache.uima.util.XMLParser.ParsingOptions)
*/
+ @Override
public void buildFromXMLElement(Element aElement, XMLParser aParser, ParsingOptions aOptions)
throws InvalidXMLException {
setHref(aElement.getAttribute("href"));
@@ -72,28 +89,42 @@ public class CpeResourceManagerConfigura
/**
* Overridden to handle "href" attributes.
- *
+ *
+ * @return the XML attributes
* @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXMLAttributes()
*/
+ @Override
protected AttributesImpl getXMLAttributes() {
AttributesImpl attrs = super.getXMLAttributes();
attrs.addAttribute("", "href", "href", "CDATA", getHref());
return attrs;
}
+ /** The Constant XMLIZATION_INFO. */
static final private XmlizationInfo XMLIZATION_INFO = new XmlizationInfo(
"resourceManagerConfiguration", new PropertyXmlInfo[0]);
+ /* (non-Javadoc)
+ * @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXmlizationInfo()
+ */
+ @Override
protected XmlizationInfo getXmlizationInfo() {
return XMLIZATION_INFO;
}
+ /**
+ * Gets the href.
+ *
+ * @return the href
+ */
public String getHref() {
return href;
}
/**
- * @param string
+ * Sets the href.
+ *
+ * @param string the new href
*/
public void setHref(String string) {
href = string;
Modified: uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeSofaMappingImpl.java
URL: http://svn.apache.org/viewvc/uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeSofaMappingImpl.java?rev=1769397&r1=1769396&r2=1769397&view=diff
==============================================================================
--- uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeSofaMappingImpl.java (original)
+++ uima/uimaj/branches/experiment-v3-jcas/uimaj-cpe/src/main/java/org/apache/uima/collection/impl/metadata/cpe/CpeSofaMappingImpl.java Sat Nov 12 18:26:08 2016
@@ -30,25 +30,40 @@ import org.w3c.dom.Element;
import org.w3c.dom.NamedNodeMap;
import org.xml.sax.helpers.AttributesImpl;
+// TODO: Auto-generated Javadoc
+/**
+ * The Class CpeSofaMappingImpl.
+ */
public class CpeSofaMappingImpl extends MetaDataObject_impl implements CpeSofaMapping {
+
+ /** The Constant serialVersionUID. */
private static final long serialVersionUID = -2488866857646083657L;
+ /** The component sofa name. */
private String componentSofaName;
+ /** The cpe sofa name. */
private String cpeSofaName;
+ /* (non-Javadoc)
+ * @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXmlizationInfo()
+ */
+ @Override
protected XmlizationInfo getXmlizationInfo() {
return XMLIZATION_INFO;
}
+ /** The Constant XMLIZATION_INFO. */
static final private XmlizationInfo XMLIZATION_INFO = new XmlizationInfo("sofaNameMapping",
new PropertyXmlInfo[0]);
/**
* Overridden to handle "name" and "value" attributes.
- *
+ *
+ * @return the XML attributes
* @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#getXMLAttributes()
*/
+ @Override
protected AttributesImpl getXMLAttributes() {
AttributesImpl attrs = super.getXMLAttributes();
try {
@@ -67,10 +82,15 @@ public class CpeSofaMappingImpl extends
/**
* Overridden to read "name" and "value" attributes.
- *
+ *
+ * @param aElement the a element
+ * @param aParser the a parser
+ * @param aOptions the a options
+ * @throws InvalidXMLException the invalid XML exception
* @see org.apache.uima.resource.metadata.impl.MetaDataObject_impl#buildFromXMLElement(org.w3c.dom.Element,
* org.apache.uima.util.XMLParser, org.apache.uima.util.XMLParser.ParsingOptions)
*/
+ @Override
public void buildFromXMLElement(Element aElement, XMLParser aParser, ParsingOptions aOptions)
throws InvalidXMLException {
// assumes all children are parameter elements
@@ -80,29 +100,41 @@ public class CpeSofaMappingImpl extends
}
/**
+ * Gets the component sofa name.
+ *
* @return component sofa name
*/
+ @Override
public String getComponentSofaName() {
return componentSofaName;
}
/**
+ * Gets the cpe sofa name.
+ *
* @return cpe sofa name
*/
+ @Override
public String getCpeSofaName() {
return cpeSofaName;
}
/**
- * @param string
+ * Sets the component sofa name.
+ *
+ * @param string the new component sofa name
*/
+ @Override
public void setComponentSofaName(String string) {
componentSofaName = string;
}
/**
- * @param string
+ * Sets the cpe sofa name.
+ *
+ * @param string the new cpe sofa name
*/
+ @Override
public void setCpeSofaName(String string) {
cpeSofaName = string;
}