public class ASB_impl extends Resource_ImplBase implements ASB
ASB
implementation. This implementation is not specific to any transport
technology. It simply uses the ResourceFactory
to acquire instances of its delegate
AnalysisEngines and then communicates with these delegate AnalysisEngines through the
AnalysisEngine
interface. Any communication with remote AnalysisEngine services is done
through a AnalysisEngineServiceAdapter
and
is not the concern of this ASB implementation.PARAM_AGGREGATE_ANALYSIS_ENGINE_NAME
PARAM_AGGREGATE_SOFA_MAPPINGS, PARAM_CONFIG_MANAGER, PARAM_CONFIG_PARAM_SETTINGS, PARAM_EXTERNAL_OVERRIDE_SETTINGS, PARAM_PERFORMANCE_TUNING_SETTINGS, PARAM_RESOURCE_MANAGER, PARAM_UIMA_CONTEXT
Constructor and Description |
---|
ASB_impl() |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
Releases all resources held by this
Resource . |
Map<String,ProcessingResourceMetaData> |
getAllComponentMetaData()
Gets the metadata for all components known to this ASB.
|
Map<String,AnalysisEngineMetaData> |
getComponentAnalysisEngineMetaData()
Gets metadata for all of the component AnalysisEngines known to this
ASB . |
Map<String,AnalysisEngine> |
getComponentAnalysisEngines()
Gets references to the component AnalysisEngines known to this
ASB . |
FlowControllerContainer |
getFlowControllerContainer()
Not public API.
|
protected AnalysisEngineManagementImpl |
getMBean()
Gets the MBean that provides the management interface to this AE.
|
protected void |
initFlowController(FlowControllerDeclaration aFlowControllerDeclaration,
UimaContextAdmin aParentContext,
AnalysisEngineMetaData aAggregateMetadata) |
boolean |
initialize(ResourceSpecifier aSpecifier,
Map<String,Object> aAdditionalParams)
Initializes this ASB.
|
CasIterator |
process(CAS aCAS)
Invokes the processing of the aggregate on the given input CAS.
|
void |
setup(Map<String,ResourceSpecifier> aSpecifiers,
UimaContextAdmin aParentContext,
FlowControllerDeclaration aFlowControllerDeclaration,
AnalysisEngineMetaData aAggregateMetadata)
Called after calling initialize() (see above) by the Aggregate Analysis Engine to provide this
ASB with information it needs to operate.
|
getCasManager, getLogger, getMetaData, getRelativePathResolver, getResourceManager, getUimaContext, getUimaContextAdmin, loadUserClass, loadUserClassOrThrow, setContextHolder, setContextHolderX, setLogger, setMetaData, withContextHolder
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getLogger, getMetaData, getResourceManager, getUimaContext, getUimaContextAdmin, setLogger
public boolean initialize(ResourceSpecifier aSpecifier, Map<String,Object> aAdditionalParams) throws ResourceInitializationException
initialize
in interface Resource
initialize
in class Resource_ImplBase
aSpecifier
- describes how to create this ASB.aAdditionalParams
- parameters which are passed along to the delegate Analysis Engines when they are
constructedResourceSpecifier
.ResourceInitializationException
- if a failure occurs during initialization.Resource.initialize(ResourceSpecifier, Map)
public void destroy()
Resource
Resource
.destroy
in interface Resource
destroy
in class Resource_ImplBase
Resource.destroy()
public void setup(Map<String,ResourceSpecifier> aSpecifiers, UimaContextAdmin aParentContext, FlowControllerDeclaration aFlowControllerDeclaration, AnalysisEngineMetaData aAggregateMetadata) throws ResourceInitializationException
setup
in interface ASB
aSpecifiers
- the specifiers for all component AEs within this Aggregate. The ASB will instantiate
those AEs.aParentContext
- UIMA context for the aggregate AEaFlowControllerDeclaration
- declaration (key and specifier) of FlowController to be used for this aggregate.aAggregateMetadata
- metadata for the aggregate AEResourceInitializationException
- passthruprotected void initFlowController(FlowControllerDeclaration aFlowControllerDeclaration, UimaContextAdmin aParentContext, AnalysisEngineMetaData aAggregateMetadata) throws ResourceInitializationException
ResourceInitializationException
public Map<String,AnalysisEngineMetaData> getComponentAnalysisEngineMetaData()
ASB
ASB
.getComponentAnalysisEngineMetaData
in interface ASB
AnalysisEngineDescription.getDelegateAnalysisEngineSpecifiers()
to
AnalysisEngineMetaData
values.ASB.getComponentAnalysisEngineMetaData()
public Map<String,AnalysisEngine> getComponentAnalysisEngines()
ASB
ASB
.getComponentAnalysisEngines
in interface ASB
AnalysisEngineDescription.getDelegateAnalysisEngineSpecifiers()
to
AnalysisEngine
objects.ASB.getComponentAnalysisEngines()
public Map<String,ProcessingResourceMetaData> getAllComponentMetaData()
ASB
getAllComponentMetaData
in interface ASB
ProcessingResourceMetaData
values.public CasIterator process(CAS aCAS) throws AnalysisEngineProcessException
ASB
CasIterator
.
If the aggregate does not generate any output CASes of the input CAS, an empty
CasIterator
will be returned.
process
in interface ASB
aCAS
- the CAS to processAnalysisEngineProcessException
- -public FlowControllerContainer getFlowControllerContainer()
getFlowControllerContainer
in interface ASB
FlowControllerContainer
protected AnalysisEngineManagementImpl getMBean()
Copyright © 2006–2022 The Apache Software Foundation. All rights reserved.