Class Checkpoint

java.lang.Object
org.apache.uima.collection.impl.cpm.Checkpoint
All Implemented Interfaces:
Runnable

public class Checkpoint extends Object implements Runnable
Runing in a seperate thread creates a checkpoint file at predefined intervals.
  • Field Details

    • fileName

      private String fileName
    • stop

      private volatile boolean stop
    • checkpointFrequency

      private long checkpointFrequency
    • pause

      private boolean pause
    • lockForPause

      private final Object lockForPause
    • cpm

      private BaseCPMImpl cpm
    • synchPointFileName

      private String synchPointFileName
  • Constructor Details

    • Checkpoint

      public Checkpoint(BaseCPMImpl aCpm, String aFilename, long aCheckpointFrequency)
      Initialize the checkpoint with a reference to controlling cpe, the file where the checkpoint is to be stored, and the frequency of checkpoints.
      Parameters:
      aCpm -
      aFilename -
      aCheckpointFrequency -
  • Method Details

    • start

      public void start()
      Start the thread
    • stop

      public void stop()
      Stops the checkpoint thread
    • run

      public void run()
      Starts the checkpoint thread and runs until the cpe tells it to stop
      Specified by:
      run in interface Runnable
    • delete

      public void delete()
      Deletes checkpoint file from the filesystem
    • pause

      public void pause()
      Pauses checkpoint thread
    • resume

      public void resume()
      Resumes checkpoint thread
    • doCheckpoint

      public void doCheckpoint()
      Serializes checkpoint information to disk. It retrieves data to checkpoint from the CPEEngine.
    • rename

      public void rename(String aFilename)
      Renames previous checkpoint file.
      Parameters:
      aFilename - - checkpoint file to rename
    • printStats

      public static void printStats(ProcessTrace prT)
    • printEveList

      public static void printEveList(List lst, int tCnt)
      Prints the list of Process Events in the order that they were produced.
      Parameters:
      lst - List of ProcessEvent
      tCnt - depth of this List in the Process Trace hierarchy
    • exists

      public boolean exists()
      Returns true if configured checkpoinjt file exists on disk
      Returns:
      - true if file exists, false otherwise
    • restoreFromCheckpoint

      public Object restoreFromCheckpoint() throws IOException
      Retrieves the checkpoint from the filesystem.
      Returns:
      - desirialized object containing recovery information.
      Throws:
      IOException - -