org.apache.uima.aae.controller
public interface AggregateAnalysisEngineController extends AnalysisEngineController
AEInstanceCount, CasPoolSize
Modifier and Type | Method and Description |
---|---|
void |
addMessageOrigin(java.lang.String aCasReferenceId,
Endpoint anEndpoint) |
void |
changeCollocatedDelegateState(java.lang.String delegateKey,
BaseAnalysisEngineController.ServiceState state) |
boolean |
continueOnError(java.lang.String aCasReferenceId,
java.lang.String aDelegateKey,
java.lang.Exception anException) |
boolean |
delayCasIfDelegateInTimedOutState(java.lang.String aCasReferenceId,
java.lang.String aDelegateKey) |
void |
disableDelegates(java.util.List aDelegateList) |
void |
dispatchMetadataRequest(Endpoint anEndpoint) |
void |
dropFlow(java.lang.String aCasReferenceId,
boolean dropFlow) |
void |
enableDelegates(java.util.List aDelegateList) |
void |
finalStep(org.apache.uima.flow.FinalStep aStep,
java.lang.String aCasReferenceId) |
java.util.List |
getChildControllerList() |
org.apache.uima.UimaContext |
getChildUimaContext(java.lang.String aDelegateEndpointName) |
ServiceErrors |
getDelegateServiceErrors(java.lang.String aDelegateKey) |
PrimitiveServiceInfo |
getDelegateServiceInfo(java.lang.String aDelegateKey) |
ServicePerformance |
getDelegateServicePerformance(java.lang.String aDelegateKey) |
java.util.Map |
getDelegateStats() |
java.util.Map |
getDestinations() |
java.lang.String |
getLastDelegateKeyFromFlow(java.lang.String anInputCasReferenceId) |
Endpoint |
getMessageOrigin(java.lang.String aCasReferenceId) |
AggregateServiceInfo |
getServiceInfo() |
ServicePerformance |
getServicePerformance(java.lang.String aDelegateKey) |
boolean |
isDelegateDisabled(java.lang.String aDelegateKey) |
boolean |
isDelegateKeyValid(java.lang.String anEndpointName) |
Delegate |
lookupDelegate(java.lang.String aDelegateKey) |
java.lang.String |
lookUpDelegateKey(java.lang.String aDelegateEndpointName) |
java.lang.String |
lookUpDelegateKey(java.lang.String aDelegateEndpointName,
java.lang.String server) |
Endpoint |
lookUpEndpoint(java.lang.String anAnalysisEngineKey,
boolean clone) |
void |
mapEndpointsToKeys(java.util.concurrent.ConcurrentHashMap aDestinationMap) |
void |
mergeTypeSystem(java.lang.String aTypeSystem,
java.lang.String fromDestination) |
void |
mergeTypeSystem(java.lang.String aTypeSystem,
java.lang.String fromDestination,
java.lang.String fromServer) |
void |
processCollectionCompleteReplyFromDelegate(java.lang.String aDelegateKey,
boolean sendReply) |
void |
registerChildController(AnalysisEngineController aChildController,
java.lang.String aDelegateKey) |
void |
removeMessageOrigin(java.lang.String aCasReferenceId) |
boolean |
requestForMetaSentToRemotes() |
void |
retryLastCommand(int aCommand,
Endpoint anEndpoint,
java.lang.String aCasReferenceId) |
void |
retryMetadataRequest(Endpoint anEndpoint) |
void |
retryProcessCASRequest(java.lang.String aCasReferenceId,
Endpoint anEndpoint,
boolean addEndpointToCache) |
void |
saveStatsFromService(java.lang.String aServiceEndpointName,
java.util.Map aServiceStats) |
void |
sendRequestForMetadataToRemoteDelegates() |
void |
setCasLoggingDirectory(java.lang.String key,
java.lang.String directoryName) |
void |
setRequestForMetaSentToRemotes() |
void |
stopCasMultiplier(Delegate casMultiplier,
java.lang.String aCasReferenceId) |
void |
stopTimers() |
addAbortedCasReferenceId, addInputChannel, addServiceInfo, beginProcess, cacheClientEndpoint, changeState, collectionProcessComplete, dropCAS, dropCAS, dropStats, dumpState, endProcess, forceTimeoutOnPendingCases, getAnalysisTime, getCasManagerWrapper, getCasStatistics, getClientEndpoint, getComponentName, getControllerLatch, getCpuTime, getDeadClientMap, getErrorHandlerChain, getEventListener, getIdleTime, getIdleTimeBetweenProcessCalls, getIndex, getInProcessCache, getInputChannel, getInputChannel, getJmxContext, getJMXDomain, getKey, getLocalCache, getManagementInterface, getMonitor, getName, getOutputChannel, getParentController, getReplyInputChannel, getReplyTime, getServiceEndpointName, getServiceErrors, getServicePerformance, getState, getStats, getTime, getTransport, getTransport, getUimaEEAdminContext, getUimaMessageListener, handleDelegateLifeCycleEvent, incrementDeserializationTime, incrementSerializationTime, initialize, initializeVMTransport, isAwaitingCacheCallbackNotification, isCasMultiplier, isPrimitive, isStopped, isTopLevelComponent, notifyListenersWithInitializationStatus, onInitialize, process, process, process, quiesceAndStop, registerVmQueueWithJMX, releaseNextCas, saveReplyTime, saveTime, sendMetadata, setCasManager, setDeployDescriptor, setInputChannel, setOutputChannel, setStopped, setUimaEEAdminContext, stop, takeAction
addControllerCallbackListener, removeControllerCallbackListener, terminate
void mergeTypeSystem(java.lang.String aTypeSystem, java.lang.String fromDestination) throws AsynchAEException
AsynchAEException
void mergeTypeSystem(java.lang.String aTypeSystem, java.lang.String fromDestination, java.lang.String fromServer) throws AsynchAEException
AsynchAEException
void sendRequestForMetadataToRemoteDelegates() throws AsynchAEException
AsynchAEException
void addMessageOrigin(java.lang.String aCasReferenceId, Endpoint anEndpoint)
Endpoint getMessageOrigin(java.lang.String aCasReferenceId)
void removeMessageOrigin(java.lang.String aCasReferenceId)
void processCollectionCompleteReplyFromDelegate(java.lang.String aDelegateKey, boolean sendReply) throws AsynchAEException
AsynchAEException
boolean isDelegateKeyValid(java.lang.String anEndpointName)
void mapEndpointsToKeys(java.util.concurrent.ConcurrentHashMap aDestinationMap)
Endpoint lookUpEndpoint(java.lang.String anAnalysisEngineKey, boolean clone) throws AsynchAEException
AsynchAEException
void dispatchMetadataRequest(Endpoint anEndpoint) throws AsynchAEException
AsynchAEException
void retryLastCommand(int aCommand, Endpoint anEndpoint, java.lang.String aCasReferenceId)
void retryMetadataRequest(Endpoint anEndpoint) throws AsynchAEException
AsynchAEException
java.lang.String lookUpDelegateKey(java.lang.String aDelegateEndpointName)
java.lang.String lookUpDelegateKey(java.lang.String aDelegateEndpointName, java.lang.String server)
org.apache.uima.UimaContext getChildUimaContext(java.lang.String aDelegateEndpointName) throws java.lang.Exception
getChildUimaContext
in interface AnalysisEngineController
java.lang.Exception
void retryProcessCASRequest(java.lang.String aCasReferenceId, Endpoint anEndpoint, boolean addEndpointToCache) throws AsynchAEException
AsynchAEException
void enableDelegates(java.util.List aDelegateList) throws AsynchAEException
AsynchAEException
void disableDelegates(java.util.List aDelegateList) throws AsynchAEException
AsynchAEException
boolean continueOnError(java.lang.String aCasReferenceId, java.lang.String aDelegateKey, java.lang.Exception anException) throws AsynchAEException
AsynchAEException
void dropFlow(java.lang.String aCasReferenceId, boolean dropFlow)
boolean isDelegateDisabled(java.lang.String aDelegateKey)
java.lang.String getLastDelegateKeyFromFlow(java.lang.String anInputCasReferenceId)
void registerChildController(AnalysisEngineController aChildController, java.lang.String aDelegateKey) throws java.lang.Exception
java.lang.Exception
void saveStatsFromService(java.lang.String aServiceEndpointName, java.util.Map aServiceStats)
java.util.Map getDelegateStats()
AggregateServiceInfo getServiceInfo()
getServiceInfo
in interface AnalysisEngineController
ServicePerformance getDelegateServicePerformance(java.lang.String aDelegateKey)
PrimitiveServiceInfo getDelegateServiceInfo(java.lang.String aDelegateKey)
ServiceErrors getDelegateServiceErrors(java.lang.String aDelegateKey)
void stopTimers()
boolean requestForMetaSentToRemotes()
void setRequestForMetaSentToRemotes()
java.util.Map getDestinations()
ServicePerformance getServicePerformance(java.lang.String aDelegateKey)
void finalStep(org.apache.uima.flow.FinalStep aStep, java.lang.String aCasReferenceId)
Delegate lookupDelegate(java.lang.String aDelegateKey)
boolean delayCasIfDelegateInTimedOutState(java.lang.String aCasReferenceId, java.lang.String aDelegateKey) throws AsynchAEException
AsynchAEException
java.util.List getChildControllerList()
void stopCasMultiplier(Delegate casMultiplier, java.lang.String aCasReferenceId)
void setCasLoggingDirectory(java.lang.String key, java.lang.String directoryName)
void changeCollocatedDelegateState(java.lang.String delegateKey, BaseAnalysisEngineController.ServiceState state) throws java.lang.Exception
java.lang.Exception
Copyright © 2014. All Rights Reserved.