org.apache.uima.aae.controller

Interface AggregateAnalysisEngineController

All Superinterfaces:

AnalysisEngineController, ControllerLifecycle

All Known Implementing Classes:

AggregateAnalysisEngineController_impl

public interface AggregateAnalysisEngineController
extends AnalysisEngineController

Field Summary

Fields inherited from interface org.apache.uima.aae.controller.AnalysisEngineController

AEInstanceCount, CasPoolSize

Method Summary

Modifier and Type	Method and Description
void	addMessageOrigin(String aCasReferenceId, Endpoint anEndpoint)
void	changeCollocatedDelegateState(String delegateKey, BaseAnalysisEngineController.ServiceState state)
boolean	continueOnError(String aCasReferenceId, String aDelegateKey, Exception anException)
boolean	delayCasIfDelegateInTimedOutState(String aCasReferenceId, String aDelegateKey)
void	disableDelegates(List aDelegateList)
void	dispatchMetadataRequest(Endpoint anEndpoint)
void	dropFlow(String aCasReferenceId, boolean dropFlow)
void	enableDelegates(List aDelegateList)
void	finalStep(org.apache.uima.flow.FinalStep aStep, String aCasReferenceId)
List	getChildControllerList()
org.apache.uima.UimaContext	getChildUimaContext(String aDelegateEndpointName)
ServiceErrors	getDelegateServiceErrors(String aDelegateKey)
PrimitiveServiceInfo	getDelegateServiceInfo(String aDelegateKey)
ServicePerformance	getDelegateServicePerformance(String aDelegateKey)
Map	getDelegateStats()
Map	getDestinations()
String	getLastDelegateKeyFromFlow(String anInputCasReferenceId)
Endpoint	getMessageOrigin(String aCasReferenceId)
AggregateServiceInfo	getServiceInfo()
ServicePerformance	getServicePerformance(String aDelegateKey)
boolean	isDelegateDisabled(String aDelegateKey)
boolean	isDelegateKeyValid(String anEndpointName)
Delegate	lookupDelegate(String aDelegateKey)
String	lookUpDelegateKey(String aDelegateEndpointName)
String	lookUpDelegateKey(String aDelegateEndpointName, String server)
Endpoint	lookUpEndpoint(String anAnalysisEngineKey, boolean clone)
void	mapEndpointsToKeys(ConcurrentHashMap aDestinationMap)
void	mergeTypeSystem(String aTypeSystem, String fromDestination)
void	mergeTypeSystem(String aTypeSystem, String fromDestination, String fromServer)
void	processCollectionCompleteReplyFromDelegate(String aDelegateKey, boolean sendReply)
void	registerChildController(AnalysisEngineController aChildController, String aDelegateKey)
void	removeMessageOrigin(String aCasReferenceId)
boolean	requestForMetaSentToRemotes()
void	retryLastCommand(int aCommand, Endpoint anEndpoint, String aCasReferenceId)
void	retryMetadataRequest(Endpoint anEndpoint)
void	retryProcessCASRequest(String aCasReferenceId, Endpoint anEndpoint, boolean addEndpointToCache)
void	saveStatsFromService(String aServiceEndpointName, Map aServiceStats)
void	sendRequestForMetadataToRemoteDelegates()
void	setCasLoggingDirectory(String key, String directoryName)
void	setRequestForMetaSentToRemotes()
void	stopCasMultiplier(Delegate casMultiplier, String aCasReferenceId)
void	stopTimers()

Methods inherited from interface org.apache.uima.aae.controller.AnalysisEngineController

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

Methods inherited from interface org.apache.uima.aae.controller.ControllerLifecycle

addControllerCallbackListener, removeControllerCallbackListener, terminate

Method Detail

mergeTypeSystem

void mergeTypeSystem(String aTypeSystem,
                     String fromDestination)
              throws AsynchAEException

Throws:

AsynchAEException

mergeTypeSystem

void mergeTypeSystem(String aTypeSystem,
                     String fromDestination,
                     String fromServer)
              throws AsynchAEException

Throws:

AsynchAEException

sendRequestForMetadataToRemoteDelegates

void sendRequestForMetadataToRemoteDelegates()
                                      throws AsynchAEException

Throws:

AsynchAEException

addMessageOrigin

void addMessageOrigin(String aCasReferenceId,
                      Endpoint anEndpoint)

getMessageOrigin

Endpoint getMessageOrigin(String aCasReferenceId)

removeMessageOrigin

void removeMessageOrigin(String aCasReferenceId)

processCollectionCompleteReplyFromDelegate

void processCollectionCompleteReplyFromDelegate(String aDelegateKey,
                                                boolean sendReply)
                                         throws AsynchAEException

Throws:

AsynchAEException

isDelegateKeyValid

boolean isDelegateKeyValid(String anEndpointName)

mapEndpointsToKeys

void mapEndpointsToKeys(ConcurrentHashMap aDestinationMap)

lookUpEndpoint

Endpoint lookUpEndpoint(String anAnalysisEngineKey,
                        boolean clone)
                 throws AsynchAEException

Throws:

AsynchAEException

dispatchMetadataRequest

void dispatchMetadataRequest(Endpoint anEndpoint)
                      throws AsynchAEException

Throws:

AsynchAEException

retryLastCommand

void retryLastCommand(int aCommand,
                      Endpoint anEndpoint,
                      String aCasReferenceId)

retryMetadataRequest

void retryMetadataRequest(Endpoint anEndpoint)
                   throws AsynchAEException

Throws:

AsynchAEException

lookUpDelegateKey

String lookUpDelegateKey(String aDelegateEndpointName)

lookUpDelegateKey

String lookUpDelegateKey(String aDelegateEndpointName,
                         String server)

getChildUimaContext

org.apache.uima.UimaContext getChildUimaContext(String aDelegateEndpointName)
                                         throws Exception

Specified by:

getChildUimaContext in interface AnalysisEngineController

Throws:

Exception

retryProcessCASRequest

void retryProcessCASRequest(String aCasReferenceId,
                            Endpoint anEndpoint,
                            boolean addEndpointToCache)
                     throws AsynchAEException

Throws:

AsynchAEException

enableDelegates

void enableDelegates(List aDelegateList)
              throws AsynchAEException

Throws:

AsynchAEException

disableDelegates

void disableDelegates(List aDelegateList)
               throws AsynchAEException

Throws:

AsynchAEException

continueOnError

boolean continueOnError(String aCasReferenceId,
                        String aDelegateKey,
                        Exception anException)
                 throws AsynchAEException

Throws:

AsynchAEException

dropFlow

void dropFlow(String aCasReferenceId,
              boolean dropFlow)

isDelegateDisabled

boolean isDelegateDisabled(String aDelegateKey)

getLastDelegateKeyFromFlow

String getLastDelegateKeyFromFlow(String anInputCasReferenceId)

registerChildController

void registerChildController(AnalysisEngineController aChildController,
                             String aDelegateKey)
                      throws Exception

Throws:

Exception

saveStatsFromService

void saveStatsFromService(String aServiceEndpointName,
                          Map aServiceStats)

getDelegateStats

Map getDelegateStats()

getServiceInfo

AggregateServiceInfo getServiceInfo()

Specified by:

getServiceInfo in interface AnalysisEngineController

getDelegateServicePerformance

ServicePerformance getDelegateServicePerformance(String aDelegateKey)

getDelegateServiceInfo

PrimitiveServiceInfo getDelegateServiceInfo(String aDelegateKey)

getDelegateServiceErrors

ServiceErrors getDelegateServiceErrors(String aDelegateKey)

stopTimers

void stopTimers()

requestForMetaSentToRemotes

boolean requestForMetaSentToRemotes()

setRequestForMetaSentToRemotes

void setRequestForMetaSentToRemotes()

getDestinations

Map getDestinations()

getServicePerformance

ServicePerformance getServicePerformance(String aDelegateKey)

finalStep

void finalStep(org.apache.uima.flow.FinalStep aStep,
               String aCasReferenceId)

lookupDelegate

Delegate lookupDelegate(String aDelegateKey)

delayCasIfDelegateInTimedOutState

boolean delayCasIfDelegateInTimedOutState(String aCasReferenceId,
                                          String aDelegateKey)
                                   throws AsynchAEException

Throws:

AsynchAEException

getChildControllerList

List getChildControllerList()

stopCasMultiplier

void stopCasMultiplier(Delegate casMultiplier,
                       String aCasReferenceId)

setCasLoggingDirectory

void setCasLoggingDirectory(String key,
                            String directoryName)

changeCollocatedDelegateState

void changeCollocatedDelegateState(String delegateKey,
                                   BaseAnalysisEngineController.ServiceState state)
                            throws Exception

Throws:

Exception