org.apache.uima.aae.controller
public class PrimitiveAnalysisEngineController_impl extends BaseAnalysisEngineController implements PrimitiveAnalysisEngineController
Modifier and Type | Class and Description |
---|---|
class |
PrimitiveAnalysisEngineController_impl.StackDumpTimer
The HeapDumpTimer is optionally used to dump the heap if a task takes too much time to finish.
|
BaseAnalysisEngineController.ServiceState
Modifier and Type | Field and Description |
---|---|
protected java.lang.Object |
notifyObj |
abortedCasesMap, aeDescriptor, allDelegatesAreRemote, awaitingCacheCallbackNotification, callbackMonitor, callbackReceived, clientEndpoint, cmOutstandingCASes, componentCasPoolSize, controllerListeners, currentState, deadClientDestinationMap, delegateKey, delegates, errorCount, errorHandlerChain, finalStepMux, idleTime, inputChannel, inputChannelList, inputChannelMap, jmxContext, latch, localCache, messageListeners, monitor, NO_RECOVERY, paramsMap, parentController, perCasStatistics, processPid, replyTime, resourceSpecifier, serviceErrorMap, serviceErrors, serviceInitialized, servicePerformance, statsMap, stopped, syncObject, transports, unregisteredDelegateList
AEInstanceCount, CasPoolSize
Constructor and Description |
---|
PrimitiveAnalysisEngineController_impl(AnalysisEngineController aParentController,
java.lang.String anEndpointName,
java.lang.String anAnalysisEngineDescriptor,
AsynchAECasManager aCasManager,
InProcessCache anInProcessCache,
int aWorkQueueSize,
int anAnalysisEnginePoolSize) |
PrimitiveAnalysisEngineController_impl(AnalysisEngineController aParentController,
java.lang.String anEndpointName,
java.lang.String anAnalysisEngineDescriptor,
AsynchAECasManager aCasManager,
InProcessCache anInProcessCache,
int aWorkQueueSize,
int anAnalysisEnginePoolSize,
int aComponentCasPoolSize) |
PrimitiveAnalysisEngineController_impl(AnalysisEngineController aParentController,
java.lang.String anEndpointName,
java.lang.String anAnalysisEngineDescriptor,
AsynchAECasManager aCasManager,
InProcessCache anInProcessCache,
int aWorkQueueSize,
int anAnalysisEnginePoolSize,
int aComponentCasPoolSize,
JmxManagement aJmxManagement) |
PrimitiveAnalysisEngineController_impl(AnalysisEngineController aParentController,
java.lang.String anEndpointName,
java.lang.String anAnalysisEngineDescriptor,
AsynchAECasManager aCasManager,
InProcessCache anInProcessCache,
int aWorkQueueSize,
int anAnalysisEnginePoolSize,
int aComponentCasPoolSize,
long anInitialCasHeapSize) |
PrimitiveAnalysisEngineController_impl(AnalysisEngineController aParentController,
java.lang.String anEndpointName,
java.lang.String anAnalysisEngineDescriptor,
AsynchAECasManager aCasManager,
InProcessCache anInProcessCache,
int aWorkQueueSize,
int anAnalysisEnginePoolSize,
int aComponentCasPoolSize,
long anInitialCasHeapSize,
JmxManagement aJmxManagement) |
PrimitiveAnalysisEngineController_impl(AnalysisEngineController aParentController,
java.lang.String anEndpointName,
java.lang.String anAnalysisEngineDescriptor,
AsynchAECasManager aCasManager,
InProcessCache anInProcessCache,
int aWorkQueueSize,
int anAnalysisEnginePoolSize,
JmxManagement aJmxManagement) |
PrimitiveAnalysisEngineController_impl(java.lang.String anEndpointName,
java.lang.String anAnalysisEngineDescriptor,
AsynchAECasManager aCasManager,
InProcessCache anInProcessCache,
int aWorkQueueSize,
int anAnalysisEnginePoolSize) |
Modifier and Type | Method and Description |
---|---|
void |
collectionProcessComplete(Endpoint anEndpoint) |
void |
dumpState(java.lang.StringBuffer buffer,
java.lang.String lbl1) |
protected void |
forceStackDump()
This method forces a heap and java dump.
|
int |
getAEInstanceCount() |
ControllerLatch |
getControllerLatch() |
Monitor |
getMonitor() |
protected java.lang.String |
getNameFromMetadata() |
java.lang.String |
getServiceEndpointName() |
PrimitiveServiceInfo |
getServiceInfo() |
void |
handleDelegateLifeCycleEvent(java.lang.String anEndpoint,
int aDelegateCount) |
void |
initialize() |
void |
initializeAnalysisEngine() |
boolean |
isPrimitive() |
void |
onInitialize()
Forces initialization of a Cas Pool if this is a Cas Multiplier delegate collocated with an
aggregate.
|
void |
process(org.apache.uima.cas.CAS aCAS,
java.lang.String aCasReferenceId,
Endpoint anEndpoint)
This is called when a Stop request is received from a client.
|
void |
sendMetadata(Endpoint anEndpoint) |
void |
setAnalysisEngineInstancePool(AnalysisEngineInstancePool aPool) |
void |
setMonitor(Monitor monitor) |
void |
stop()
Stops input channel(s) and initiates a shutdown of all delegates ( if this is an aggregate ).
|
void |
takeAction(java.lang.String anAction,
java.lang.String anEndpointName,
ErrorContext anErrorContext)
Executes action on error.
|
boolean |
threadAssignedToAE() |
abortGeneratingCASes, addAbortedCasReferenceId, addControllerCallbackListener, addInputChannel, addServiceInfo, beginProcess, cacheClientEndpoint, changeState, cleanUp, clearStats, dropCAS, dropCAS, dropCasStatistics, dropStats, endProcess, exceedsThresholdWithinWindow, forceTimeoutOnPendingCases, getAnalysisTime, getBrokerURL, getCasManagerWrapper, getCasMultiplierController, getCasStatistics, getChildUimaContext, getClientEndpoint, getComponentName, getCpuTime, getDeadClientMap, getDeploymentDescriptor, getDeploymentMode, getErrorHandlerChain, getEventListener, getIdleTime, getIdleTimeBetweenProcessCalls, getIndex, getInProcessCache, getInputChannel, getInputChannel, getInputQueue, getJmxContext, getJMXDomain, getKey, getLocalCache, getManagementInterface, getName, getOutputChannel, getParentController, getReplyInputChannel, getReplyTime, getResourceSpecifier, getServiceErrors, getServiceName, getServicePerformance, getState, getStats, getTime, getTotalNumberOfCASesDropped, getTotalNumberOfCASesProcessed, getTotalNumberOfCASesReceived, getTotalNumberOfErrors, getTotalTimeSpendDeSerializingCAS, getTotalTimeSpentSerializingCAS, getTotalTimeSpentWaitingForFreeCASInstance, getTransport, getTransport, getTransport, getUimaEEAdminContext, getUimaMessageListener, handleAction, handleError, incrementDeserializationTime, incrementErrorCounter, incrementSerializationTime, initializeVMTransport, isAwaitingCacheCallbackNotification, isCasMultiplier, isStopped, isTopLevelComponent, logStats, logStats, notifyListenersWithInitializationStatus, onCacheEmpty, plugInDefaultErrorHandlerChain, process, process, quiesceAndStop, registerServiceWithJMX, registerVmQueueWithJMX, registerWithAgent, releaseNextCas, removeControllerCallbackListener, resetErrorCounter, saveReplyTime, saveTime, sendMetadata, setCasManager, setDeployDescriptor, setErrorHandlerChain, setInputChannel, setJmxManagement, setOutputChannel, setStopped, setUimaEEAdminContext, stop, stopCasMultiplier, stopCasMultipliers, stopDelegateTimers, stopInputChannel, stopInputChannels, stopTransportLayer, terminate, terminate, toString
destroy, getCasManager, getLogger, getMetaData, getResourceManager, getUimaContext, getUimaContextAdmin, initialize, setLogger, setMetaData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAbortedCasReferenceId
addInputChannel, addServiceInfo, beginProcess, cacheClientEndpoint, changeState, dropCAS, dropCAS, dropStats, endProcess, forceTimeoutOnPendingCases, getAnalysisTime, getCasManagerWrapper, getCasStatistics, getChildUimaContext, getClientEndpoint, getComponentName, getCpuTime, getDeadClientMap, getErrorHandlerChain, getEventListener, getIdleTime, getIdleTimeBetweenProcessCalls, getIndex, getInProcessCache, getInputChannel, getInputChannel, getJmxContext, getJMXDomain, getKey, getLocalCache, getManagementInterface, getName, getOutputChannel, getParentController, getReplyInputChannel, getReplyTime, getServiceErrors, getServicePerformance, getState, getStats, getTime, getTransport, getTransport, getUimaEEAdminContext, getUimaMessageListener, incrementDeserializationTime, incrementSerializationTime, initializeVMTransport, isAwaitingCacheCallbackNotification, isCasMultiplier, isStopped, isTopLevelComponent, notifyListenersWithInitializationStatus, process, process, quiesceAndStop, registerVmQueueWithJMX, releaseNextCas, saveReplyTime, saveTime, setCasManager, setDeployDescriptor, setInputChannel, setOutputChannel, setStopped, setUimaEEAdminContext
addControllerCallbackListener, removeControllerCallbackListener, terminate
public PrimitiveAnalysisEngineController_impl(java.lang.String anEndpointName, java.lang.String anAnalysisEngineDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, int aWorkQueueSize, int anAnalysisEnginePoolSize) throws java.lang.Exception
java.lang.Exception
public PrimitiveAnalysisEngineController_impl(AnalysisEngineController aParentController, java.lang.String anEndpointName, java.lang.String anAnalysisEngineDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, int aWorkQueueSize, int anAnalysisEnginePoolSize) throws java.lang.Exception
java.lang.Exception
public PrimitiveAnalysisEngineController_impl(AnalysisEngineController aParentController, java.lang.String anEndpointName, java.lang.String anAnalysisEngineDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, int aWorkQueueSize, int anAnalysisEnginePoolSize, int aComponentCasPoolSize) throws java.lang.Exception
java.lang.Exception
public PrimitiveAnalysisEngineController_impl(AnalysisEngineController aParentController, java.lang.String anEndpointName, java.lang.String anAnalysisEngineDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, int aWorkQueueSize, int anAnalysisEnginePoolSize, int aComponentCasPoolSize, long anInitialCasHeapSize) throws java.lang.Exception
java.lang.Exception
public PrimitiveAnalysisEngineController_impl(AnalysisEngineController aParentController, java.lang.String anEndpointName, java.lang.String anAnalysisEngineDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, int aWorkQueueSize, int anAnalysisEnginePoolSize, int aComponentCasPoolSize, JmxManagement aJmxManagement) throws java.lang.Exception
java.lang.Exception
public PrimitiveAnalysisEngineController_impl(AnalysisEngineController aParentController, java.lang.String anEndpointName, java.lang.String anAnalysisEngineDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, int aWorkQueueSize, int anAnalysisEnginePoolSize, int aComponentCasPoolSize, long anInitialCasHeapSize, JmxManagement aJmxManagement) throws java.lang.Exception
java.lang.Exception
public PrimitiveAnalysisEngineController_impl(AnalysisEngineController aParentController, java.lang.String anEndpointName, java.lang.String anAnalysisEngineDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, int aWorkQueueSize, int anAnalysisEnginePoolSize, JmxManagement aJmxManagement) throws java.lang.Exception
java.lang.Exception
public int getAEInstanceCount()
getAEInstanceCount
in interface PrimitiveAnalysisEngineController
public void initializeAnalysisEngine() throws org.apache.uima.resource.ResourceInitializationException
initializeAnalysisEngine
in interface PrimitiveAnalysisEngineController
org.apache.uima.resource.ResourceInitializationException
public boolean threadAssignedToAE()
threadAssignedToAE
in interface PrimitiveAnalysisEngineController
public void initialize() throws AsynchAEException
initialize
in interface AnalysisEngineController
AsynchAEException
public void onInitialize()
onInitialize
in interface AnalysisEngineController
public void collectionProcessComplete(Endpoint anEndpoint)
collectionProcessComplete
in interface AnalysisEngineController
public void process(org.apache.uima.cas.CAS aCAS, java.lang.String aCasReferenceId, Endpoint anEndpoint)
process
in interface AnalysisEngineController
process
in class BaseAnalysisEngineController
aCasReferenceId
- - Id of an input CAS. The client wants to stop generation of child CASes from this
CAS.public void sendMetadata(Endpoint anEndpoint) throws AsynchAEException
sendMetadata
in interface AnalysisEngineController
AsynchAEException
public void takeAction(java.lang.String anAction, java.lang.String anEndpointName, ErrorContext anErrorContext)
takeAction
in interface AnalysisEngineController
public java.lang.String getServiceEndpointName()
getServiceEndpointName
in interface AnalysisEngineController
public ControllerLatch getControllerLatch()
getControllerLatch
in interface AnalysisEngineController
public boolean isPrimitive()
isPrimitive
in interface AnalysisEngineController
public Monitor getMonitor()
getMonitor
in interface AnalysisEngineController
public void setMonitor(Monitor monitor)
public void handleDelegateLifeCycleEvent(java.lang.String anEndpoint, int aDelegateCount)
handleDelegateLifeCycleEvent
in interface AnalysisEngineController
protected java.lang.String getNameFromMetadata()
public void setAnalysisEngineInstancePool(AnalysisEngineInstancePool aPool)
setAnalysisEngineInstancePool
in interface PrimitiveAnalysisEngineController
public PrimitiveServiceInfo getServiceInfo()
getServiceInfo
in interface AnalysisEngineController
getServiceInfo
in interface PrimitiveAnalysisEngineController
public void stop()
BaseAnalysisEngineController
stop
in interface AnalysisEngineController
stop
in class BaseAnalysisEngineController
protected final void forceStackDump()
public void dumpState(java.lang.StringBuffer buffer, java.lang.String lbl1)
dumpState
in interface AnalysisEngineController
dumpState
in class BaseAnalysisEngineController
Copyright © 2014. All Rights Reserved.