public class CPEConfig extends Object
Constructor and Description |
---|
CPEConfig() |
Modifier and Type | Method and Description |
---|---|
CheckpointConfig |
getChConfig()
Returns CPE checkpoint configuration
|
String |
getDeployAs()
Returns CPE statup mode as defined in the CPE descriptor
|
long |
getInputQueueMaxMemoryThreshold() |
long |
getMaxTimeToWait() |
long |
getNumToProcess()
Returns number of entities to process by the CPE.
|
String |
getOutputQueueClass() |
String |
getStartWith()
Returns an id of the first entity the
CollectionReader will be told to read |
String |
getTimerClass()
Returns the name of custom
UimaTimer class. |
void |
setChConfig(CheckpointConfig config)
Copies Checkpoint configuration
|
void |
setDeployAs(String aCpeDeployMode)
Copies CPE startup mode
|
void |
setInputQueueMaxMemoryThreshold(long aInputQueueMaxMemoryThreshold) |
void |
setMaxTimeToWait(long aMaxTimeToWait) |
void |
setNumToProcess(long aTotalCount)
Copies number of entities to process
|
void |
setOutputQueueClass(String aOutputQueueClass) |
void |
setStartWith(String aStartEntityId)
Copies ind of the first entity to start reading
|
void |
setTimerClass(String aTimerClass)
Copies a name of the custom
UimaTimer class |
public CheckpointConfig getChConfig()
public String getDeployAs()
public long getNumToProcess()
public String getStartWith()
CollectionReader
will be told to readpublic String getTimerClass()
UimaTimer
class.public void setChConfig(CheckpointConfig config)
config
- -
checkpoint configurationpublic void setDeployAs(String aCpeDeployMode)
aCpeDeployMode
- -
startup modepublic void setNumToProcess(long aTotalCount)
aTotalCount
- -
total number of entities to processpublic void setStartWith(String aStartEntityId)
aStartEntityId
- -
id of entitypublic void setTimerClass(String aTimerClass)
UimaTimer
classaTimerClass
- -
timer classpublic long getInputQueueMaxMemoryThreshold()
public void setInputQueueMaxMemoryThreshold(long aInputQueueMaxMemoryThreshold)
public long getMaxTimeToWait()
public void setMaxTimeToWait(long aMaxTimeToWait)
public String getOutputQueueClass()
public void setOutputQueueClass(String aOutputQueueClass)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.