Package org.apache.uima.collection.impl.cpm.container

Class CasProcessorConfigurationJAXBImpl

java.lang.Object

org.apache.uima.collection.impl.cpm.container.CasProcessorConfigurationJAXBImpl

All Implemented Interfaces:

CasProcessorConfiguration

public class CasProcessorConfigurationJAXBImpl
extends Object
implements CasProcessorConfiguration

A wrapper containing CAS Processor configuration. An instance of this class is associated with each CAS Processor.

Constructor Summary

Constructors

Constructor	Description
CasProcessorConfigurationJAXBImpl(CpeCasProcessor aCasProcessorConfig, ResourceManager aResourceManager)	Initializes instance and copies configuration from CPE descriptor.

Method Summary

Modifier and Type	Method	Description
String	getActionOnError()	Returns an action as String to identify an action to take in case of excessive Cas Processor errors.
String	getActionOnMaxRestart()	Returns an action as String to identify an action to take in case of excessive Cas Processor restarts.
int	getBatchSize()	Returns configured batch size setup for this Cas Processor
String	getDeploymentParameter(String aDeployParameter)	Returns a value for a given deployment parameter
List<NameValuePair>	getDeploymentParameters()	Returns a list of deployment parameters associated with this CAS Processor
String	getDeploymentType()	Returns deployment type associated with this CAS Processor integrated local remote
URL	getDescriptorUrl()	Returns descriptor associated with this Cas Processor
int	getErrorRate()
long	getErrorSampleSize()
Execute	getExecSpec()	Returns executable section of the CAS Processor configuration.
LinkedList	getFilter()	Returns parsed filter expressions as List.
String	getFilterString()
String[]	getKeysToDrop()	Returns an array of types that should not be sent to CAS Processor.
int	getMaxErrorCount()	Returns max number of tolerated errors
int	getMaxRestartCount()	Returns max number of Cas Processor restarts
int	getMaxRetryCount()	Returns max number of tries to process each bundle of Cas
int	getMaxTimeToWaitBetweenRetries()	Returns how long to wait between re-sending CAS after failure
String	getName()	Returns Cas Processor name
long	getTimeout()	Returns the max amount of time the CPE will wait for CAS Processor response.
boolean	isJavaProcess()	Returns true it the CAS Processor is written in java and will be run with Java JVM.
boolean	isParallelizable()	Returns if the Cas Processor is able to run in parallel
boolean	readOnly()	Returns if the Cas Processor is read only
boolean	runInSeparateProcess()	Returns true if this CAS Processor will run in its own process

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CasProcessorConfigurationJAXBImpl

public CasProcessorConfigurationJAXBImpl(CpeCasProcessor aCasProcessorConfig,
 ResourceManager aResourceManager)
                                  throws ResourceConfigurationException

Initializes instance and copies configuration from CPE descriptor.

Parameters:

aCasProcessorConfig - - configuration object containing CAS Processor configuration

aResourceManager - - needed to resolve import by name

Throws:

ResourceConfigurationException - if descriptor error

Method Details

getMaxTimeToWaitBetweenRetries

public int getMaxTimeToWaitBetweenRetries()

Returns how long to wait between re-sending CAS after failure

Specified by:

getMaxTimeToWaitBetweenRetries in interface CasProcessorConfiguration

isParallelizable

public boolean isParallelizable()

Returns if the Cas Processor is able to run in parallel

Returns:

- true if the component can run in parallel, false otherwise

readOnly

public boolean readOnly()

Returns if the Cas Processor is read only

Returns:

- true if read only, false otherwise

getActionOnError

public String getActionOnError()

Returns an action as String to identify an action to take in case of excessive Cas Processor errors.

• continue
• terminate
• disable

Specified by:

getActionOnError in interface CasProcessorConfiguration

Returns:

- action

getActionOnMaxRestart

public String getActionOnMaxRestart()

Returns an action as String to identify an action to take in case of excessive Cas Processor restarts.

• continue
• terminate
• disable

Specified by:

getActionOnMaxRestart in interface CasProcessorConfiguration

Returns:

- action

getErrorRate

public int getErrorRate()

Specified by:

getErrorRate in interface CasProcessorConfiguration

getErrorSampleSize

public long getErrorSampleSize()

Specified by:

getErrorSampleSize in interface CasProcessorConfiguration

getMaxErrorCount

public int getMaxErrorCount()

Returns max number of tolerated errors

Specified by:

getMaxErrorCount in interface CasProcessorConfiguration

Returns:

- max number of allowed errors

getMaxRestartCount

public int getMaxRestartCount()

Returns max number of Cas Processor restarts

Specified by:

getMaxRestartCount in interface CasProcessorConfiguration

Returns:

- max number of restarts

getMaxRetryCount

public int getMaxRetryCount()

Returns max number of tries to process each bundle of Cas

Specified by:

getMaxRetryCount in interface CasProcessorConfiguration

Returns:

- max retry count

getName

public String getName()

Returns Cas Processor name

Specified by:

getName in interface CasProcessorConfiguration

Returns:

- Name

getTimeout

public long getTimeout()

Returns the max amount of time the CPE will wait for CAS Processor response.

Specified by:

getTimeout in interface CasProcessorConfiguration

Returns:

- value for timeout

getDeploymentParameters

public List<NameValuePair> getDeploymentParameters()

Returns a list of deployment parameters associated with this CAS Processor

Specified by:

getDeploymentParameters in interface CasProcessorConfiguration

Returns:

- deployment parameters as List

getDeploymentType

public String getDeploymentType()

Returns deployment type associated with this CAS Processor

• integrated
• local
• remote

Specified by:

getDeploymentType in interface CasProcessorConfiguration

Returns:

- deployment type

getFilterString

public String getFilterString()

Specified by:

getFilterString in interface CasProcessorConfiguration

Returns:

unparsed filter expression

getFilter

public LinkedList getFilter()
                     throws ResourceConfigurationException

Returns parsed filter expressions as List.

Specified by:

getFilter in interface CasProcessorConfiguration

Throws:

ResourceConfigurationException

getKeysToDrop

public String[] getKeysToDrop()
                       throws ResourceConfigurationException

Returns an array of types that should not be sent to CAS Processor. The drop types are defined in the CPE descriptor.

Specified by:

getKeysToDrop in interface CasProcessorConfiguration

Throws:

ResourceConfigurationException

getBatchSize

public int getBatchSize()

Returns configured batch size setup for this Cas Processor

Specified by:

getBatchSize in interface CasProcessorConfiguration

Returns:

- batch size

getDescriptorUrl

public URL getDescriptorUrl()
                     throws ResourceConfigurationException

Returns descriptor associated with this Cas Processor

Specified by:

getDescriptorUrl in interface CasProcessorConfiguration

Returns:

object that identifies location of descriptor

Throws:

ResourceConfigurationException - if an import could not be resolved

getDeploymentParameter

public String getDeploymentParameter(String aDeployParameter)

Returns a value for a given deployment parameter

Specified by:

getDeploymentParameter in interface CasProcessorConfiguration

Parameters:

aDeployParameter - - name of the parameter

Returns:

- value for parameter name

runInSeparateProcess

public boolean runInSeparateProcess()

Returns true if this CAS Processor will run in its own process

Specified by:

runInSeparateProcess in interface CasProcessorConfiguration

Returns:

- true if running in separate process

isJavaProcess

public boolean isJavaProcess()

Returns true it the CAS Processor is written in java and will be run with Java JVM.

Specified by:

isJavaProcess in interface CasProcessorConfiguration

getExecSpec

public Execute getExecSpec()

Returns executable section of the CAS Processor configuration. It contains the name of executable program to be used when launching a separate process with CAS Processor running as Vinci service.

Specified by:

getExecSpec in interface CasProcessorConfiguration

Returns:

- Execute object