Package org.apache.uima.collection.impl.metadata.cpe

Class CpeCasProcessorsImpl

java.lang.Object

org.apache.uima.resource.metadata.impl.MetaDataObject_impl

org.apache.uima.collection.impl.metadata.cpe.CpeCasProcessorsImpl

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, CpeCasProcessors, MetaDataObject, XMLizable

public class CpeCasProcessorsImpl
extends MetaDataObject_impl
implements CpeCasProcessors

The Class CpeCasProcessorsImpl.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.uima.resource.metadata.impl.MetaDataObject_impl

MetaDataObject_impl.MetaDataAttr, MetaDataObject_impl.SerialContext, MetaDataObject_impl.Serializer

Field Summary

Fields

Modifier and Type	Field	Description
private int	casPoolSize	The cas pool size.
private java.util.ArrayList	casProcessors	The cas processors.
private static int	DEFAULT_POOL_SIZE	The Constant DEFAULT_POOL_SIZE.
private boolean	dropCasOnException	The drop cas on exception.
private int	inputQueueSize	The input queue size.
private int	outputQueueSize	The output queue size.
private int	processingUnitThreadCount	The processing unit thread count.
private static long	serialVersionUID	The Constant serialVersionUID.
private static XmlizationInfo	XMLIZATION_INFO	The Constant XMLIZATION_INFO.

Fields inherited from class org.apache.uima.resource.metadata.impl.MetaDataObject_impl

serialContext

Constructor Summary

Constructors

Constructor	Description
CpeCasProcessorsImpl()	Instantiates a new cpe cas processors impl.

Method Summary

Modifier and Type	Method	Description
void	addCpeCasProcessor(CpeCasProcessor aCasProcessor)	Appends new CasProcessor to existing list of CasProcessors
void	addCpeCasProcessor(CpeCasProcessor aCasProcessor, int aInsertPosition)	Inserts a new CasProcessor at an indicated position.
void	buildFromXMLElement(org.w3c.dom.Element aElement, XMLParser aParser, XMLParser.ParsingOptions aOptions)	Overridden to read Cas Processor attributes.
CpeCasProcessor[]	getAllCpeCasProcessors()	Returns ALL CpeCasProcessor objects in processing pipeline.
int	getCasPoolSize()
int	getConcurrentPUCount()	Returns number of ProcessingUnits.
CpeCasProcessor	getCpeCasProcessor(int aPosition)	Returns CpeCasProcessor found at given position.
boolean	getDropCasOnException()
int	getInputQueueSize()	Returns size of the InputQueue.
int	getOutputQueueSize()	Returns the size of the OutputQueue.
int	getPoolSize()	Gets the pool size.
protected org.xml.sax.helpers.AttributesImpl	getXMLAttributes()	Overridden to handle Cas Processor attributes.
protected XmlizationInfo	getXmlizationInfo()	To be implemented by subclasses to return information describing how to represent this object in XML.
boolean	isDropCasOnException()	Checks if is drop cas on exception.
void	removeAllCpeCasProcessors()	Removes ALL CpeCasProcessor objects from processing pipeline.
void	removeCpeCasProcessor(int aPosition)	Removes CpeCasProcessor object from processing pipeline from a given position.
CpeCasProcessor[]	removeCpeCasProcessor(int aPosition, boolean flag)	New API 01/06/2006.
void	setAllCpeCasProcessors(CpeCasProcessor[] aCpeProcessors)	Sets the all cpe cas processors.
void	setConcurrentPUCount(int aConcurrentPUCount)	Sets ProcessingUnit replication.
void	setDropCasOnException(boolean aDropCasOnException)	Sets the drop cas on exception.
void	setInputQueueSize(int aInputQueueSize)	Sets the size of the InputQueue.
void	setOutputQueueSize(int aOutputQueueSize)	Sets the size of the OutputQueue.
void	setPoolSize(int aPoolSize)
void	toXML(org.xml.sax.ContentHandler aContentHandler, boolean aWriteDefaultNamespaceAttribute)	Writes this object's XML representation by making calls on a SAX ContentHandler.

Methods inherited from class org.apache.uima.resource.metadata.impl.MetaDataObject_impl

buildFromXMLElement, clone, equals, getAdditionalAttributes, getAttributeClass, getAttributeValue, getInfoset, getMatchingNode, getPropertyDescriptors, getPropertyXmlInfo, getRelativePathBase, getSerialContext, getSourceUrl, getSourceUrlString, getWrapperClass, hashCode, isModifiable, listAttributes, readArrayPropertyValueFromXMLElement, readMapPropertyFromXml, readPropertyValueFromXMLElement, readUnknownPropertyValueFromXMLElement, resolveSettings, setAttributeValue, setInfoset, setSourceUrl, setSourceUrlIfNull, toString, toXML, toXML, toXML, valueIsNullOrEmptyArray, writeArrayPropertyAsElement, writeMapPropertyToXml, writePropertyAsElement

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.uima.resource.metadata.MetaDataObject

clone, equals, getAttributeValue, getSourceUrl, getSourceUrlString, isModifiable, listAttributes, setAttributeValue, setSourceUrl

Methods inherited from interface org.apache.uima.util.XMLizable

buildFromXMLElement, toXML, toXML, toXML

Field Detail

serialVersionUID

private static final long serialVersionUID

The Constant serialVersionUID.

See Also:

Constant Field Values

DEFAULT_POOL_SIZE

private static final int DEFAULT_POOL_SIZE

The Constant DEFAULT_POOL_SIZE.

See Also:

Constant Field Values

casProcessors

private java.util.ArrayList casProcessors

The cas processors.

dropCasOnException

private boolean dropCasOnException

The drop cas on exception.

casPoolSize

private int casPoolSize

The cas pool size.

processingUnitThreadCount

private int processingUnitThreadCount

The processing unit thread count.

inputQueueSize

private int inputQueueSize

The input queue size.

outputQueueSize

private int outputQueueSize

The output queue size.

XMLIZATION_INFO

private static final XmlizationInfo XMLIZATION_INFO

The Constant XMLIZATION_INFO.

Constructor Detail

CpeCasProcessorsImpl

public CpeCasProcessorsImpl()

Instantiates a new cpe cas processors impl.

Method Detail

setOutputQueueSize

public void setOutputQueueSize(int aOutputQueueSize)
                        throws CpeDescriptorException

Description copied from interface: CpeCasProcessors

Sets the size of the OutputQueue. This queue is shared among Processing Units and CasConsumers and contains bundles of CAS. Processing Units add bundles to the queue while CasConsumers consume them. The best size for this queue is determined by overall performance of the ProcessingUnit ( how fast it deposits bundles onto the queue) and memory availability. The larger the queue the more bundles (hence memory) is used.

Specified by:

setOutputQueueSize in interface CpeCasProcessors

Parameters:

aOutputQueueSize - - Output queue size

Throws:

CpeDescriptorException - tbd

getOutputQueueSize

public int getOutputQueueSize()

Description copied from interface: CpeCasProcessors

Returns the size of the OutputQueue. This queue is shared among Processing Units and CasConsumers and contains bundles of CAS. Processing Units add bundles to the queue while CasConsumers consume them. The best size for this queue is determined by overall performance of the ProcessingUnit ( how fast it deposits bundles onto the queue) and memory availability. The larger the queue the more bundles (hence memory) is used.

Specified by:

getOutputQueueSize in interface CpeCasProcessors

Returns:

- output queue size

setInputQueueSize

public void setInputQueueSize(int aInputQueueSize)
                       throws CpeDescriptorException

Description copied from interface: CpeCasProcessors

Sets the size of the InputQueue. This queue is shared among CollectionReader and Processing Units and contains bundles of CAS. CollectionReader adds bundles to the queue while Processing Unit consume them. The best size for this queue is determined by overall performance of the ProcessingUnit ( how fast it takes bundles off the queue) and memory availability. The larger the queue the more bundles (hence memory) is used.

Specified by:

setInputQueueSize in interface CpeCasProcessors

Parameters:

aInputQueueSize - - queue size

Throws:

CpeDescriptorException - tbd

getInputQueueSize

public int getInputQueueSize()

Description copied from interface: CpeCasProcessors

Returns size of the InputQueue. This queue is shared among CollectionReader and Processing Units and contains bundles of CAS. CollectionReader adds bundles to the queue while Processing Unit consume them. The best size for this queue is determined by overall performance of the ProcessingUnit ( how fast it takes bundles off the queue) and memory availability. The larger the queue the more bundles (hence memory) is used.

Specified by:

getInputQueueSize in interface CpeCasProcessors

Returns:

- queue size

setConcurrentPUCount

public void setConcurrentPUCount(int aConcurrentPUCount)
                          throws CpeDescriptorException

Description copied from interface: CpeCasProcessors

Sets ProcessingUnit replication. Each ProcessingUnit contains the same sequence of CasProcessors and runs in a seperate thread. On platforms containing more than one CPU, replicating ProcessingUnit may result in better performance.

Specified by:

setConcurrentPUCount in interface CpeCasProcessors

Parameters:

aConcurrentPUCount - - number of ProcessingUnits(processing threads)

Throws:

CpeDescriptorException - tbd

getConcurrentPUCount

public int getConcurrentPUCount()

Description copied from interface: CpeCasProcessors

Returns number of ProcessingUnits. Each ProcessingUnit contains the same sequence of CasProcessors and runs in a seperate thread. On platforms containing more than one CPU, replicating ProcessingUnit may result in better performance.

Specified by:

getConcurrentPUCount in interface CpeCasProcessors

Returns:

- number of ProcessingUnits(processing threads)

addCpeCasProcessor

public void addCpeCasProcessor(CpeCasProcessor aCasProcessor,
                               int aInsertPosition)
                        throws CpeDescriptorException

Description copied from interface: CpeCasProcessors

Inserts a new CasProcessor at an indicated position.

Specified by:

addCpeCasProcessor in interface CpeCasProcessors

Parameters:

aCasProcessor - - CasProcessor to add

aInsertPosition - - position where to insert the CasProcessor

Throws:

CpeDescriptorException - tbd

addCpeCasProcessor

public void addCpeCasProcessor(CpeCasProcessor aCasProcessor)
                        throws CpeDescriptorException

Description copied from interface: CpeCasProcessors

Appends new CasProcessor to existing list of CasProcessors

Specified by:

addCpeCasProcessor in interface CpeCasProcessors

Parameters:

aCasProcessor - - CasProcessor to add

Throws:

CpeDescriptorException - tbd

getCpeCasProcessor

public CpeCasProcessor getCpeCasProcessor(int aPosition)
                                   throws CpeDescriptorException

Description copied from interface: CpeCasProcessors

Returns CpeCasProcessor found at given position.

Specified by:

getCpeCasProcessor in interface CpeCasProcessors

Parameters:

aPosition - - position of the CasProcessor

Returns:

- CpeCasProcessor

Throws:

CpeDescriptorException - tbd

getAllCpeCasProcessors

public CpeCasProcessor[] getAllCpeCasProcessors()
                                         throws CpeDescriptorException

Description copied from interface: CpeCasProcessors

Returns ALL CpeCasProcessor objects in processing pipeline.

Specified by:

getAllCpeCasProcessors in interface CpeCasProcessors

Returns:

array of CpeCasProcessor

Throws:

CpeDescriptorException - tbd

setAllCpeCasProcessors

public void setAllCpeCasProcessors(CpeCasProcessor[] aCpeProcessors)
                            throws CpeDescriptorException

Sets the all cpe cas processors.

Parameters:

aCpeProcessors - the new all cpe cas processors

Throws:

CpeDescriptorException - the cpe descriptor exception

removeCpeCasProcessor

public void removeCpeCasProcessor(int aPosition)
                           throws CpeDescriptorException

Description copied from interface: CpeCasProcessors

Removes CpeCasProcessor object from processing pipeline from a given position.

Specified by:

removeCpeCasProcessor in interface CpeCasProcessors

Parameters:

aPosition - - position of the CasProcessor in the pipeline

Throws:

CpeDescriptorException - tbd

removeCpeCasProcessor

public CpeCasProcessor[] removeCpeCasProcessor(int aPosition,
                                               boolean flag)
                                        throws CpeDescriptorException

New API 01/06/2006.

Parameters:

aPosition - the a position

flag - the flag

Returns:

the cpe cas processor[]

Throws:

CpeDescriptorException - the cpe descriptor exception

removeAllCpeCasProcessors

public void removeAllCpeCasProcessors()
                               throws CpeDescriptorException

Description copied from interface: CpeCasProcessors

Removes ALL CpeCasProcessor objects from processing pipeline.

Specified by:

removeAllCpeCasProcessors in interface CpeCasProcessors

Throws:

CpeDescriptorException - tbd

setPoolSize

public void setPoolSize(int aPoolSize)
                 throws CpeDescriptorException

Specified by:

setPoolSize in interface CpeCasProcessors

Throws:

CpeDescriptorException

getPoolSize

public int getPoolSize()
                throws CpeDescriptorException

Gets the pool size.

Returns:

the pool size

Throws:

CpeDescriptorException - the cpe descriptor exception

setDropCasOnException

public void setDropCasOnException(boolean aDropCasOnException)
                           throws CpeDescriptorException

Sets the drop cas on exception.

Parameters:

aDropCasOnException - the new drop cas on exception

Throws:

CpeDescriptorException - the cpe descriptor exception

getDropCasOnException

public boolean getDropCasOnException()

Specified by:

getDropCasOnException in interface CpeCasProcessors

buildFromXMLElement

public void buildFromXMLElement(org.w3c.dom.Element aElement,
                                XMLParser aParser,
                                XMLParser.ParsingOptions aOptions)
                         throws InvalidXMLException

Overridden to read Cas Processor attributes.

Specified by:

buildFromXMLElement in interface XMLizable

Overrides:

buildFromXMLElement in class MetaDataObject_impl

Parameters:

aElement - the a element

aParser - the a parser

aOptions - the a options

Throws:

InvalidXMLException - the invalid XML exception

See Also:

MetaDataObject_impl.buildFromXMLElement(org.w3c.dom.Element, org.apache.uima.util.XMLParser, org.apache.uima.util.XMLParser.ParsingOptions)

toXML

public void toXML(org.xml.sax.ContentHandler aContentHandler,
                  boolean aWriteDefaultNamespaceAttribute)
           throws org.xml.sax.SAXException

Description copied from interface: XMLizable

Writes this object's XML representation by making calls on a SAX ContentHandler.

Specified by:

toXML in interface XMLizable

Overrides:

toXML in class MetaDataObject_impl

Parameters:

aContentHandler - the content handler to which this object will write events that describe its XML representation.

aWriteDefaultNamespaceAttribute - whether the namespace of this element should be written as the default namespace. This should be done only for the root element, and it defaults to false.

Throws:

org.xml.sax.SAXException - pass thru

See Also:

This is called internally, also for JSon serialization If this is the first call to serialize, create a serialContext (and clean up afterwards) Other callers (e.g. JSON) must set the serialContext first before calling

getXMLAttributes

protected org.xml.sax.helpers.AttributesImpl getXMLAttributes()

Overridden to handle Cas Processor attributes.

Overrides:

getXMLAttributes in class MetaDataObject_impl

Returns:

the XML attributes

See Also:

MetaDataObject_impl.getXMLAttributes()

getXmlizationInfo

protected XmlizationInfo getXmlizationInfo()

Description copied from class: MetaDataObject_impl

To be implemented by subclasses to return information describing how to represent this object in XML.

Specified by:

getXmlizationInfo in class MetaDataObject_impl

Returns:

information defining this object's XML representation

getCasPoolSize

public int getCasPoolSize()

Specified by:

getCasPoolSize in interface CpeCasProcessors

isDropCasOnException

public boolean isDropCasOnException()

Checks if is drop cas on exception.

Returns:

true, if is drop cas on exception