Package org.apache.uima.collection.impl.cpm

Class CPEConfig

java.lang.Object
org.apache.uima.collection.impl.cpm.CPEConfig
public class CPEConfig extends Object
Object containing global cpe configuration.

  • Constructor Details

    • CPEConfig

      public CPEConfig()

  • Method Details

    • getChConfig

      public CheckpointConfig getChConfig()
      Returns CPE checkpoint configuration
      Returns:
      CheckpointConfig object

    • getDeployAs

      public String getDeployAs()
      Returns CPE statup mode as defined in the CPE descriptor
      Returns:
      - statup mode

    • getNumToProcess

      public long getNumToProcess()
      Returns number of entities to process by the CPE.
      Returns:
      - number of entities to process

    • getStartWith

      public String getStartWith()
      Returns an id of the first entity the CollectionReader will be told to read
      Returns:
      - id of the first entity to read

    • getTimerClass

      public String getTimerClass()
      Returns the name of custom UimaTimer class.
      Returns:
      - class as String

    • setChConfig

      public void setChConfig(CheckpointConfig config)
      Copies Checkpoint configuration
      Parameters:
      config - - checkpoint configuration

    • setDeployAs

      public void setDeployAs(String aCpeDeployMode)
      Copies CPE startup mode
      Parameters:
      aCpeDeployMode - - startup mode

    • setNumToProcess

      public void setNumToProcess(long aTotalCount)
      Copies number of entities to process
      Parameters:
      aTotalCount - - total number of entities to process

    • setStartWith

      public void setStartWith(String aStartEntityId)
      Copies ind of the first entity to start reading
      Parameters:
      aStartEntityId - - id of entity

    • setTimerClass

      public void setTimerClass(String aTimerClass)
      Copies a name of the custom UimaTimer class
      Parameters:
      aTimerClass - - timer class

    • getInputQueueMaxMemoryThreshold

      public long getInputQueueMaxMemoryThreshold()

    • setInputQueueMaxMemoryThreshold

      public void setInputQueueMaxMemoryThreshold(long aInputQueueMaxMemoryThreshold)

    • getMaxTimeToWait

      public long getMaxTimeToWait()

    • setMaxTimeToWait

      public void setMaxTimeToWait(long aMaxTimeToWait)

    • getOutputQueueClass

      public String getOutputQueueClass()

    • setOutputQueueClass

      public void setOutputQueueClass(String aOutputQueueClass)