public class AggregateDelegateEngineImpl extends Object implements AggregateDelegateEngine
Constructor and Description |
---|
AggregateDelegateEngineImpl(org.apache.uima.resourceSpecifier.AnalysisEngineType dcaet,
String key,
ServiceContext context,
DelegateConfiguration... delegateConfigurations)
Instantiates a new aggregate delegate engine impl.
|
Modifier and Type | Method and Description |
---|---|
void |
addDelegate(DelegateAnalysisEngine delegate)
Adds the delegate.
|
CasMultiplier |
getCasMultiplier()
Gets the cas multiplier.
|
DelegateConfiguration |
getConfiguration()
Gets the configuration.
|
List<DelegateAnalysisEngine> |
getDelegates()
Gets the delegates.
|
int |
getInputQueueScaleout()
Gets the input queue scaleout.
|
String |
getKey()
Gets the key.
|
int |
getReplyQueueScaleup()
Gets the reply queue scaleup.
|
boolean |
isAggregate()
Checks if is aggregate.
|
boolean |
isAsync()
Checks if is async.
|
boolean |
isRemote()
Checks if is remote.
|
void |
setAsync()
Sets the async.
|
void |
setCasMultiplier(CasMultiplier cm)
Sets the cas multiplier.
|
void |
setInputQueueScaleout(int scaleup)
Sets the input queue scaleout.
|
void |
setKey(String key)
Sets the key.
|
void |
setReplyQueueScaleup(int scaleup)
Sets the reply queue scaleup.
|
public AggregateDelegateEngineImpl(org.apache.uima.resourceSpecifier.AnalysisEngineType dcaet, String key, ServiceContext context, DelegateConfiguration... delegateConfigurations)
dcaet
- the dcaetkey
- the keycontext
- the contextdelegateConfigurations
- the delegate configurationspublic boolean isRemote()
DelegateAnalysisEngine
isRemote
in interface DelegateAnalysisEngine
public boolean isAggregate()
DelegateAnalysisEngine
isAggregate
in interface DelegateAnalysisEngine
public boolean isAsync()
ColocatedDelegateEngine
isAsync
in interface ColocatedDelegateEngine
public void setAsync()
ColocatedDelegateEngine
setAsync
in interface ColocatedDelegateEngine
public int getInputQueueScaleout()
ColocatedDelegateEngine
getInputQueueScaleout
in interface ColocatedDelegateEngine
public void setInputQueueScaleout(int scaleup)
ColocatedDelegateEngine
setInputQueueScaleout
in interface ColocatedDelegateEngine
scaleup
- the new input queue scaleoutpublic String getKey()
DelegateAnalysisEngine
getKey
in interface DelegateAnalysisEngine
public void setKey(String key)
DelegateAnalysisEngine
setKey
in interface DelegateAnalysisEngine
key
- the new keypublic int getReplyQueueScaleup()
DelegateAnalysisEngine
getReplyQueueScaleup
in interface DelegateAnalysisEngine
public void setReplyQueueScaleup(int scaleup)
DelegateAnalysisEngine
setReplyQueueScaleup
in interface DelegateAnalysisEngine
scaleup
- the new reply queue scaleuppublic CasMultiplier getCasMultiplier()
DelegateAnalysisEngine
getCasMultiplier
in interface DelegateAnalysisEngine
public void setCasMultiplier(CasMultiplier cm)
DelegateAnalysisEngine
setCasMultiplier
in interface DelegateAnalysisEngine
cm
- the new cas multiplierpublic void addDelegate(DelegateAnalysisEngine delegate)
AggregateDelegateEngine
addDelegate
in interface AggregateDelegateEngine
delegate
- the delegatepublic List<DelegateAnalysisEngine> getDelegates()
AggregateDelegateEngine
getDelegates
in interface AggregateDelegateEngine
public DelegateConfiguration getConfiguration()
DelegateAnalysisEngine
getConfiguration
in interface DelegateAnalysisEngine
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.