org.apache.uima.collection.impl.cpm
Class Checkpoint

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

public class Checkpoint
extends java.lang.Object
implements java.lang.Runnable

Runing in a seperate thread creates a checkpoint file at predefined intervals.


Constructor Summary
Checkpoint(BaseCPMImpl aCpm, java.lang.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.
 
Method Summary
 void delete()
          Deletes checkpoint file from the filesystem
 void doCheckpoint()
          Serializes checkpoint information to disk.
 boolean exists()
          Returns true if configured checkpoinjt file exists on disk
 void pause()
          Pauses checkpoint thread
static void printEveList(java.util.List lst, int tCnt)
          Prints the list of Process Events in the order that they were produced.
static void printStats(ProcessTrace prT)
           
 void rename(java.lang.String aFilename)
          Renames previous checkpoint file.
 java.lang.Object restoreFromCheckpoint()
          Retrieves the checkpoint from the filesystem.
 void resume()
          Resumes checkpoint thread
 void run()
          Starts the checkpoint thread and runs until the cpe tells it to stop
 void start()
          Start the thread
 void stop()
          Stops the checkpoint thread
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Checkpoint

public Checkpoint(BaseCPMImpl aCpm,
                  java.lang.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 Detail

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 java.lang.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(java.lang.String aFilename)
Renames previous checkpoint file.

Parameters:
aFilename - - checkpoint file to rename

printStats

public static void printStats(ProcessTrace prT)

printEveList

public static void printEveList(java.util.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 java.lang.Object restoreFromCheckpoint()
                                       throws java.io.IOException
Retrieves the checkpoint from the filesystem.

Returns:
- desirialized object containing recovery information.
Throws:
java.io.IOException


Copyright © 2011. All Rights Reserved.