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

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 Details
- 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

Interface AggregateAnalysisEngineController

Field Summary

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

Method Summary

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

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

Method Details

mergeTypeSystem

mergeTypeSystem

sendRequestForMetadataToRemoteDelegates

addMessageOrigin

getMessageOrigin

removeMessageOrigin

processCollectionCompleteReplyFromDelegate

isDelegateKeyValid

mapEndpointsToKeys

lookUpEndpoint

dispatchMetadataRequest

retryLastCommand

retryMetadataRequest

lookUpDelegateKey

lookUpDelegateKey

getChildUimaContext

retryProcessCASRequest

enableDelegates

disableDelegates

continueOnError

dropFlow

isDelegateDisabled

getLastDelegateKeyFromFlow

registerChildController

saveStatsFromService

getDelegateStats

getServiceInfo

getDelegateServicePerformance

getDelegateServiceInfo

getDelegateServiceErrors

stopTimers

requestForMetaSentToRemotes

setRequestForMetaSentToRemotes

getDestinations

getServicePerformance

finalStep

lookupDelegate

delayCasIfDelegateInTimedOutState

getChildControllerList

stopCasMultiplier

setCasLoggingDirectory

changeCollocatedDelegateState