|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.uima.resource.Resource_ImplBase
org.apache.uima.aae.controller.BaseAnalysisEngineController
public abstract class BaseAnalysisEngineController
Nested Class Summary | |
---|---|
static class |
BaseAnalysisEngineController.ServiceState
|
Field Summary | |
---|---|
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.String> |
abortedCasesMap
|
protected java.lang.String |
aeDescriptor
|
protected boolean |
allDelegatesAreRemote
|
protected boolean |
awaitingCacheCallbackNotification
|
protected java.lang.Object |
callbackMonitor
|
protected boolean |
callbackReceived
|
protected Endpoint |
clientEndpoint
|
protected java.util.concurrent.ConcurrentHashMap |
cmOutstandingCASes
|
protected int |
componentCasPoolSize
|
protected java.util.List |
controllerListeners
|
protected BaseAnalysisEngineController.ServiceState |
currentState
|
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.String> |
deadClientDestinationMap
|
protected java.lang.String |
delegateKey
|
protected java.util.List<Delegate> |
delegates
|
protected long |
errorCount
|
protected ErrorHandlerChain |
errorHandlerChain
|
protected java.lang.Object |
finalStepMux
|
protected long |
idleTime
|
protected InputChannel |
inputChannel
|
protected java.util.List |
inputChannelList
|
protected java.util.concurrent.ConcurrentHashMap |
inputChannelMap
|
protected java.lang.String |
jmxContext
|
protected ControllerLatch |
latch
|
protected LocalCache |
localCache
|
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,UimaMessageListener> |
messageListeners
|
protected Monitor |
monitor
|
static boolean |
NO_RECOVERY
|
protected java.util.HashMap |
paramsMap
|
protected AnalysisEngineController |
parentController
|
protected java.util.concurrent.ConcurrentHashMap |
perCasStatistics
|
protected java.lang.String |
processPid
|
protected long |
replyTime
|
protected org.apache.uima.resource.ResourceSpecifier |
resourceSpecifier
|
protected java.util.concurrent.ConcurrentHashMap |
serviceErrorMap
|
protected ServiceErrors |
serviceErrors
|
protected boolean |
serviceInitialized
|
protected ServicePerformance |
servicePerformance
|
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Long> |
statsMap
|
protected boolean |
stopped
|
protected java.lang.Object |
syncObject
|
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,UimaTransport> |
transports
|
protected java.util.List |
unregisteredDelegateList
|
Fields inherited from interface org.apache.uima.aae.controller.AnalysisEngineController |
---|
AEInstanceCount, CasPoolSize |
Fields inherited from interface org.apache.uima.resource.Resource |
---|
PARAM_AGGREGATE_SOFA_MAPPINGS, PARAM_CONFIG_PARAM_SETTINGS, PARAM_PERFORMANCE_TUNING_SETTINGS, PARAM_RESOURCE_MANAGER, PARAM_UIMA_CONTEXT |
Constructor Summary | |
---|---|
BaseAnalysisEngineController()
|
|
BaseAnalysisEngineController(AnalysisEngineController aParentController,
int aComponentCasPoolSize,
long anInitialCasHeapSize,
java.lang.String anEndpointName,
java.lang.String aDescriptor,
AsynchAECasManager aCasManager,
InProcessCache anInProcessCache,
java.util.Map aDestinationMap,
JmxManagement aJmxManagement)
|
|
BaseAnalysisEngineController(AnalysisEngineController aParentController,
int aComponentCasPoolSize,
java.lang.String anEndpointName,
java.lang.String aDescriptor,
AsynchAECasManager aCasManager,
InProcessCache anInProcessCache)
|
|
BaseAnalysisEngineController(AnalysisEngineController aParentController,
int aComponentCasPoolSize,
java.lang.String anEndpointName,
java.lang.String aDescriptor,
AsynchAECasManager aCasManager,
InProcessCache anInProcessCache,
java.util.Map aDestinationMap)
|
|
BaseAnalysisEngineController(AnalysisEngineController aParentController,
int aComponentCasPoolSize,
java.lang.String anEndpointName,
java.lang.String aDescriptor,
AsynchAECasManager aCasManager,
InProcessCache anInProcessCache,
java.util.Map aDestinationMap,
JmxManagement aJmxManagement)
|
Method Summary | |
---|---|
protected boolean |
abortGeneratingCASes(java.lang.String aCasReferenceId)
Returns true if a given CAS id is in the list of aborted CASes. |
void |
addAbortedCasReferenceId(java.lang.String aCasReferenceId)
|
void |
addControllerCallbackListener(ControllerCallbackListener aListener)
Register one or more listeners through which the controller can send notification of events. |
void |
addInputChannel(InputChannel anInputChannel)
|
void |
addServiceInfo(ServiceInfo aServiceInfo)
|
void |
beginProcess(int msgType)
|
void |
cacheClientEndpoint(Endpoint anEndpoint)
|
void |
changeState(BaseAnalysisEngineController.ServiceState state)
|
protected void |
cleanUp()
|
protected void |
clearStats()
Clears controller statistics. |
void |
dropCAS(org.apache.uima.cas.CAS aCAS)
|
void |
dropCAS(java.lang.String aCasReferenceId,
boolean deleteCacheEntry)
|
protected void |
dropCasStatistics(java.lang.String aCasReferenceId)
|
void |
dropStats(java.lang.String aCasReferenceId,
java.lang.String anEndpointName)
Removes statistics from the global Map |
abstract void |
dumpState(java.lang.StringBuffer buffer,
java.lang.String lbl1)
|
void |
endProcess(int msgType)
|
protected boolean |
exceedsThresholdWithinWindow(int threshold,
long docCount,
int windowSize)
|
void |
forceTimeoutOnPendingCases(java.lang.String key)
|
long |
getAnalysisTime()
Returns the total CPU time all processing threads spent in analysis. |
java.lang.String |
getBrokerURL()
|
AsynchAECasManager |
getCasManagerWrapper()
|
AnalysisEngineController |
getCasMultiplierController(java.lang.String cmKey)
Aggregates have more than one Listener channel. |
ServicePerformance |
getCasStatistics(java.lang.String aCasReferenceId)
Returns stats associated with a given CAS. |
org.apache.uima.UimaContext |
getChildUimaContext(java.lang.String aDelegateEndpointName)
|
Endpoint |
getClientEndpoint()
|
java.lang.String |
getComponentName()
Returns the name of the component. |
long |
getCpuTime()
Returns CPU Time with nanosecond precision (not nanosecond accuracy). |
java.util.Map<java.lang.String,java.lang.String> |
getDeadClientMap()
|
java.lang.String |
getDeploymentDescriptor()
|
java.lang.String |
getDeploymentMode()
|
ErrorHandlerChain |
getErrorHandlerChain()
|
EventSubscriber |
getEventListener()
Returns interface via which this instance receives callbacks |
long |
getIdleTime()
|
long |
getIdleTimeBetweenProcessCalls(int msgType)
|
int |
getIndex()
Returns a unique id for each component in the service hierarchy. |
InProcessCache |
getInProcessCache()
|
InputChannel |
getInputChannel()
|
InputChannel |
getInputChannel(java.lang.String anEndpointName)
|
java.lang.String |
getInputQueue()
|
java.lang.String |
getJmxContext()
This is called once during initialization to compute the position of the component in the JMX hierarchy and create a context path that will be used to register the component in the JMX registry. |
java.lang.String |
getJMXDomain()
Get the domain for Uima JMX. |
java.lang.String |
getKey()
|
LocalCache |
getLocalCache()
|
JmxManagement |
getManagementInterface()
|
java.lang.String |
getName()
|
OutputChannel |
getOutputChannel()
|
AnalysisEngineController |
getParentController()
|
InputChannel |
getReplyInputChannel(java.lang.String aDelegateKey)
|
long |
getReplyTime()
|
protected org.apache.uima.resource.ResourceSpecifier |
getResourceSpecifier()
|
ServiceErrors |
getServiceErrors()
|
java.lang.String |
getServiceName()
|
ServicePerformance |
getServicePerformance()
|
BaseAnalysisEngineController.ServiceState |
getState()
|
java.util.Map |
getStats()
Returns a copy of the controller statistics. |
long |
getTime(java.lang.String aCasReferenceId,
java.lang.String anEndpointName)
|
long |
getTotalNumberOfCASesDropped()
|
long |
getTotalNumberOfCASesProcessed()
|
long |
getTotalNumberOfCASesReceived()
|
long |
getTotalNumberOfErrors()
|
long |
getTotalTimeSpendDeSerializingCAS()
|
long |
getTotalTimeSpentSerializingCAS()
|
long |
getTotalTimeSpentWaitingForFreeCASInstance()
|
UimaTransport |
getTransport(java.lang.String aKey)
|
UimaTransport |
getTransport(UimaAsContext asContext)
|
UimaTransport |
getTransport(UimaAsContext asContext,
java.lang.String aKey)
|
UimaEEAdminContext |
getUimaEEAdminContext()
|
UimaMessageListener |
getUimaMessageListener(java.lang.String aDelegateKey)
|
protected void |
handleAction(java.lang.String anAction,
java.lang.String anEndpoint,
ErrorContext anErrorContext)
|
void |
handleError(java.util.HashMap aMap,
java.lang.Throwable e)
|
void |
incrementDeserializationTime(long cpuTime)
Increments the time this thread spent in deserialization of a CAS |
protected void |
incrementErrorCounter()
|
void |
incrementSerializationTime(long cpuTime)
Increments the time this thread spent in serialization of a CAS |
void |
initializeVMTransport(int parentControllerReplyConsumerCount)
Initializes transport used for internal messaging between collocated Uima AS services. |
boolean |
isAwaitingCacheCallbackNotification()
|
boolean |
isCasMultiplier()
|
boolean |
isStopped()
Return true if this service is in the shutdown state |
boolean |
isTopLevelComponent()
|
protected void |
logStats()
|
protected void |
logStats(java.lang.String aDelegateKey,
ServicePerformance aServicePerformance)
Logs statistics |
void |
notifyListenersWithInitializationStatus(java.lang.Exception e)
|
void |
onCacheEmpty()
Callback method called the InProcessCache becomes empty meaning ALL CASes are processed. |
protected void |
plugInDefaultErrorHandlerChain()
|
void |
process(org.apache.uima.cas.CAS aCas,
java.lang.String aCasId)
|
void |
process(org.apache.uima.cas.CAS aCAS,
java.lang.String aCasReferenceId,
Endpoint anEndpoint)
|
void |
process(org.apache.uima.cas.CAS aCAS,
java.lang.String anInputCasReferenceId,
java.lang.String aNewCasReferenceId,
java.lang.String newCASProducedBy)
|
void |
quiesceAndStop()
Stops input channel(s) and waits for CASes still in play to complete processing. |
protected void |
registerServiceWithJMX(java.lang.String key_value_list,
boolean remote)
|
void |
registerVmQueueWithJMX(java.lang.Object o,
java.lang.String aName)
|
protected void |
registerWithAgent(java.lang.Object o,
java.lang.String aName)
Register a component with a given name with JMX MBeanServer |
void |
releaseNextCas(java.lang.String casReferenceId)
|
void |
removeControllerCallbackListener(ControllerCallbackListener aListener)
Removes named application listener. |
protected void |
resetErrorCounter()
|
void |
saveReplyTime(long snapshot,
java.lang.String aKey)
|
void |
saveTime(long aTime,
java.lang.String aCasReferenceId,
java.lang.String anEndpointName)
|
void |
sendMetadata(Endpoint anEndpoint,
org.apache.uima.analysis_engine.metadata.AnalysisEngineMetaData metadata)
|
void |
setCasManager(AsynchAECasManager casManager)
|
void |
setDeployDescriptor(java.lang.String aDeployDescriptor)
|
void |
setErrorHandlerChain(ErrorHandlerChain errorHandlerChain)
|
void |
setInputChannel(InputChannel anInputChannel)
|
void |
setJmxManagement(JmxManagement aJmxManagement)
Override the default JmxManager |
void |
setOutputChannel(OutputChannel outputChannel)
|
void |
setStopped()
Called to set the state of the AnalysisEngineController to STOPPED. |
void |
setUimaEEAdminContext(UimaEEAdminContext anAdminContext)
|
void |
stop()
Stops input channel(s) and initiates a shutdown of all delegates ( if this is an aggregate ). |
void |
stop(java.lang.Throwable cause,
java.lang.String aCasReferenceId)
|
void |
stopCasMultiplier(Delegate casMultiplier,
java.lang.String aCasReferenceId)
|
void |
stopCasMultipliers()
|
protected void |
stopDelegateTimers()
|
protected void |
stopInputChannel()
Stops a listener on the main input channel |
protected void |
stopInputChannels(int channelsToStop)
|
protected void |
stopTransportLayer()
|
void |
terminate()
Using a reference to its parent, propagates the terminate event to the top level controller. |
void |
terminate(java.lang.Throwable cause,
java.lang.String aCasReferenceId)
|
java.lang.String |
toString()
Print the component name rather than the class name |
Methods inherited from class org.apache.uima.resource.Resource_ImplBase |
---|
destroy, getCasManager, getLogger, getMetaData, getResourceManager, getUimaContext, getUimaContextAdmin, initialize, setLogger, setMetaData |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.uima.aae.controller.AnalysisEngineController |
---|
collectionProcessComplete, getControllerLatch, getMonitor, getServiceEndpointName, getServiceInfo, handleDelegateLifeCycleEvent, initialize, isPrimitive, onInitialize, sendMetadata, takeAction |
Field Detail |
---|
public static final boolean NO_RECOVERY
protected BaseAnalysisEngineController.ServiceState currentState
protected volatile ControllerLatch latch
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Long> statsMap
protected Monitor monitor
protected Endpoint clientEndpoint
protected AnalysisEngineController parentController
protected org.apache.uima.resource.ResourceSpecifier resourceSpecifier
protected java.util.HashMap paramsMap
protected InputChannel inputChannel
protected ErrorHandlerChain errorHandlerChain
protected long errorCount
protected java.util.List inputChannelList
protected java.util.concurrent.ConcurrentHashMap inputChannelMap
protected int componentCasPoolSize
protected long replyTime
protected long idleTime
protected java.util.concurrent.ConcurrentHashMap serviceErrorMap
protected java.lang.String jmxContext
protected ServicePerformance servicePerformance
protected ServiceErrors serviceErrors
protected volatile boolean stopped
protected java.lang.String delegateKey
protected java.util.List unregisteredDelegateList
protected volatile boolean allDelegatesAreRemote
protected java.util.List controllerListeners
protected volatile boolean serviceInitialized
protected java.util.concurrent.ConcurrentHashMap perCasStatistics
protected java.lang.Object syncObject
protected java.util.concurrent.ConcurrentHashMap cmOutstandingCASes
protected final java.lang.Object finalStepMux
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,UimaTransport> transports
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,UimaMessageListener> messageListeners
protected LocalCache localCache
protected java.lang.String aeDescriptor
protected java.util.List<Delegate> delegates
protected volatile boolean callbackReceived
protected java.lang.Object callbackMonitor
protected volatile boolean awaitingCacheCallbackNotification
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.String> abortedCasesMap
protected java.lang.String processPid
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.String> deadClientDestinationMap
Constructor Detail |
---|
public BaseAnalysisEngineController()
public BaseAnalysisEngineController(AnalysisEngineController aParentController, int aComponentCasPoolSize, java.lang.String anEndpointName, java.lang.String aDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache) throws java.lang.Exception
java.lang.Exception
public BaseAnalysisEngineController(AnalysisEngineController aParentController, int aComponentCasPoolSize, java.lang.String anEndpointName, java.lang.String aDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, java.util.Map aDestinationMap) throws java.lang.Exception
java.lang.Exception
public BaseAnalysisEngineController(AnalysisEngineController aParentController, int aComponentCasPoolSize, java.lang.String anEndpointName, java.lang.String aDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, java.util.Map aDestinationMap, JmxManagement aJmxManagement) throws java.lang.Exception
java.lang.Exception
public BaseAnalysisEngineController(AnalysisEngineController aParentController, int aComponentCasPoolSize, long anInitialCasHeapSize, java.lang.String anEndpointName, java.lang.String aDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, java.util.Map aDestinationMap, JmxManagement aJmxManagement) throws java.lang.Exception
java.lang.Exception
Method Detail |
---|
public abstract void dumpState(java.lang.StringBuffer buffer, java.lang.String lbl1)
dumpState
in interface AnalysisEngineController
public AnalysisEngineController getParentController()
getParentController
in interface AnalysisEngineController
public UimaTransport getTransport(java.lang.String aKey) throws java.lang.Exception
getTransport
in interface AnalysisEngineController
java.lang.Exception
public UimaTransport getTransport(UimaAsContext asContext) throws java.lang.Exception
java.lang.Exception
public UimaTransport getTransport(UimaAsContext asContext, java.lang.String aKey) throws java.lang.Exception
getTransport
in interface AnalysisEngineController
java.lang.Exception
public void initializeVMTransport(int parentControllerReplyConsumerCount) throws java.lang.Exception
initializeVMTransport
in interface AnalysisEngineController
java.lang.Exception
public UimaMessageListener getUimaMessageListener(java.lang.String aDelegateKey)
getUimaMessageListener
in interface AnalysisEngineController
public java.lang.String getJMXDomain()
getJMXDomain
in interface AnalysisEngineController
public JmxManagement getManagementInterface()
getManagementInterface
in interface AnalysisEngineController
public int getIndex()
getIndex
in interface AnalysisEngineController
public java.lang.String getJmxContext()
getJmxContext
in interface AnalysisEngineController
protected void registerWithAgent(java.lang.Object o, java.lang.String aName)
o
- - component to register with JMXaName
- - full jmx context name for the componentpublic void registerVmQueueWithJMX(java.lang.Object o, java.lang.String aName) throws java.lang.Exception
registerVmQueueWithJMX
in interface AnalysisEngineController
java.lang.Exception
protected void registerServiceWithJMX(java.lang.String key_value_list, boolean remote)
protected void cleanUp() throws java.lang.Exception
java.lang.Exception
public void setJmxManagement(JmxManagement aJmxManagement)
public boolean isTopLevelComponent()
isTopLevelComponent
in interface AnalysisEngineController
public java.lang.String getComponentName()
getComponentName
in interface AnalysisEngineController
public java.lang.String toString()
toString
in class java.lang.Object
public void addServiceInfo(ServiceInfo aServiceInfo)
addServiceInfo
in interface AnalysisEngineController
public ServicePerformance getServicePerformance()
getServicePerformance
in interface AnalysisEngineController
public ServiceErrors getServiceErrors()
getServiceErrors
in interface AnalysisEngineController
public org.apache.uima.UimaContext getChildUimaContext(java.lang.String aDelegateEndpointName) throws java.lang.Exception
getChildUimaContext
in interface AnalysisEngineController
java.lang.Exception
public void setInputChannel(InputChannel anInputChannel) throws java.lang.Exception
setInputChannel
in interface AnalysisEngineController
java.lang.Exception
public void addInputChannel(InputChannel anInputChannel)
addInputChannel
in interface AnalysisEngineController
public InputChannel getInputChannel()
getInputChannel
in interface AnalysisEngineController
public void dropCAS(org.apache.uima.cas.CAS aCAS)
dropCAS
in interface AnalysisEngineController
public void saveReplyTime(long snapshot, java.lang.String aKey)
saveReplyTime
in interface AnalysisEngineController
public long getReplyTime()
getReplyTime
in interface AnalysisEngineController
protected void handleAction(java.lang.String anAction, java.lang.String anEndpoint, ErrorContext anErrorContext) throws java.lang.Exception
java.lang.Exception
public void forceTimeoutOnPendingCases(java.lang.String key)
forceTimeoutOnPendingCases
in interface AnalysisEngineController
protected void plugInDefaultErrorHandlerChain()
public void setErrorHandlerChain(ErrorHandlerChain errorHandlerChain)
public ErrorHandlerChain getErrorHandlerChain()
getErrorHandlerChain
in interface AnalysisEngineController
public void handleError(java.util.HashMap aMap, java.lang.Throwable e)
public void dropCAS(java.lang.String aCasReferenceId, boolean deleteCacheEntry)
dropCAS
in interface AnalysisEngineController
public void saveTime(long aTime, java.lang.String aCasReferenceId, java.lang.String anEndpointName)
saveTime
in interface AnalysisEngineController
public long getTime(java.lang.String aCasReferenceId, java.lang.String anEndpointName)
getTime
in interface AnalysisEngineController
protected void resetErrorCounter()
protected void incrementErrorCounter()
protected boolean exceedsThresholdWithinWindow(int threshold, long docCount, int windowSize)
public OutputChannel getOutputChannel()
getOutputChannel
in interface AnalysisEngineController
public void setOutputChannel(OutputChannel outputChannel) throws java.lang.Exception
setOutputChannel
in interface AnalysisEngineController
java.lang.Exception
public AsynchAECasManager getCasManagerWrapper()
getCasManagerWrapper
in interface AnalysisEngineController
public void setCasManager(AsynchAECasManager casManager)
setCasManager
in interface AnalysisEngineController
public InProcessCache getInProcessCache()
getInProcessCache
in interface AnalysisEngineController
protected org.apache.uima.resource.ResourceSpecifier getResourceSpecifier()
public java.lang.String getName()
getName
in interface AnalysisEngineController
public java.lang.String getKey()
getKey
in interface AnalysisEngineController
public void process(org.apache.uima.cas.CAS aCas, java.lang.String aCasId)
process
in interface AnalysisEngineController
public void process(org.apache.uima.cas.CAS aCAS, java.lang.String anInputCasReferenceId, java.lang.String aNewCasReferenceId, java.lang.String newCASProducedBy)
process
in interface AnalysisEngineController
public void process(org.apache.uima.cas.CAS aCAS, java.lang.String aCasReferenceId, Endpoint anEndpoint)
process
in interface AnalysisEngineController
public void setUimaEEAdminContext(UimaEEAdminContext anAdminContext)
setUimaEEAdminContext
in interface AnalysisEngineController
public UimaEEAdminContext getUimaEEAdminContext()
getUimaEEAdminContext
in interface AnalysisEngineController
public void dropStats(java.lang.String aCasReferenceId, java.lang.String anEndpointName)
dropStats
in interface AnalysisEngineController
protected void logStats()
public ServicePerformance getCasStatistics(java.lang.String aCasReferenceId)
getCasStatistics
in interface AnalysisEngineController
protected void logStats(java.lang.String aDelegateKey, ServicePerformance aServicePerformance)
aDelegateKey
- aDelegateServicePerformance
- protected void clearStats()
public java.util.Map getStats()
getStats
in interface AnalysisEngineController
public void setDeployDescriptor(java.lang.String aDeployDescriptor)
setDeployDescriptor
in interface AnalysisEngineController
public java.lang.String getServiceName()
public java.lang.String getDeploymentDescriptor()
public java.lang.String getDeploymentMode()
public java.lang.String getBrokerURL()
public java.lang.String getInputQueue()
public long getTotalTimeSpentSerializingCAS()
public long getTotalTimeSpendDeSerializingCAS()
public long getTotalTimeSpentWaitingForFreeCASInstance()
public long getTotalNumberOfCASesReceived()
public long getTotalNumberOfCASesProcessed()
public long getTotalNumberOfCASesDropped()
public long getTotalNumberOfErrors()
public Endpoint getClientEndpoint()
getClientEndpoint
in interface AnalysisEngineController
public void cacheClientEndpoint(Endpoint anEndpoint)
cacheClientEndpoint
in interface AnalysisEngineController
anEndpoint
- public boolean isStopped()
isStopped
in interface AnalysisEngineController
public void setStopped()
AnalysisEngineController
setStopped
in interface AnalysisEngineController
protected void stopTransportLayer()
public void stop()
stop
in interface AnalysisEngineController
public void stop(java.lang.Throwable cause, java.lang.String aCasReferenceId)
public void quiesceAndStop()
quiesceAndStop
in interface AnalysisEngineController
protected void stopDelegateTimers()
public void terminate()
terminate
in interface ControllerLifecycle
public void terminate(java.lang.Throwable cause, java.lang.String aCasReferenceId)
public void stopCasMultipliers()
public void stopCasMultiplier(Delegate casMultiplier, java.lang.String aCasReferenceId)
protected void stopInputChannel()
protected void stopInputChannels(int channelsToStop)
public AnalysisEngineController getCasMultiplierController(java.lang.String cmKey)
public InputChannel getInputChannel(java.lang.String anEndpointName)
getInputChannel
in interface AnalysisEngineController
public InputChannel getReplyInputChannel(java.lang.String aDelegateKey)
getReplyInputChannel
in interface AnalysisEngineController
public void onCacheEmpty()
onCacheEmpty
in interface EventSubscriber
public EventSubscriber getEventListener()
getEventListener
in interface AnalysisEngineController
public void addControllerCallbackListener(ControllerCallbackListener aListener)
addControllerCallbackListener
in interface ControllerLifecycle
aListener
- - application listener object to registerpublic void removeControllerCallbackListener(ControllerCallbackListener aListener)
removeControllerCallbackListener
in interface ControllerLifecycle
aListener
- - application listener to removepublic void notifyListenersWithInitializationStatus(java.lang.Exception e)
notifyListenersWithInitializationStatus
in interface AnalysisEngineController
protected void dropCasStatistics(java.lang.String aCasReferenceId)
public boolean isCasMultiplier()
isCasMultiplier
in interface AnalysisEngineController
public void releaseNextCas(java.lang.String casReferenceId)
releaseNextCas
in interface AnalysisEngineController
public void beginProcess(int msgType)
beginProcess
in interface AnalysisEngineController
public void endProcess(int msgType)
endProcess
in interface AnalysisEngineController
public long getIdleTimeBetweenProcessCalls(int msgType)
getIdleTimeBetweenProcessCalls
in interface AnalysisEngineController
public long getIdleTime()
getIdleTime
in interface AnalysisEngineController
public long getCpuTime()
getCpuTime
in interface AnalysisEngineController
public long getAnalysisTime()
getAnalysisTime
in interface AnalysisEngineController
public void incrementSerializationTime(long cpuTime)
incrementSerializationTime
in interface AnalysisEngineController
public void incrementDeserializationTime(long cpuTime)
incrementDeserializationTime
in interface AnalysisEngineController
public void sendMetadata(Endpoint anEndpoint, org.apache.uima.analysis_engine.metadata.AnalysisEngineMetaData metadata)
public LocalCache getLocalCache()
getLocalCache
in interface AnalysisEngineController
public void addAbortedCasReferenceId(java.lang.String aCasReferenceId)
addAbortedCasReferenceId
in interface AnalysisEngineController
protected boolean abortGeneratingCASes(java.lang.String aCasReferenceId)
aCasReferenceId
- - id of the current input CAS being processed
public boolean isAwaitingCacheCallbackNotification()
isAwaitingCacheCallbackNotification
in interface AnalysisEngineController
public void changeState(BaseAnalysisEngineController.ServiceState state)
changeState
in interface AnalysisEngineController
public BaseAnalysisEngineController.ServiceState getState()
getState
in interface AnalysisEngineController
public java.util.Map<java.lang.String,java.lang.String> getDeadClientMap()
getDeadClientMap
in interface AnalysisEngineController
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |