org.apache.s4.core.ft
Class CheckpointingTask

java.lang.Object
  extended by java.util.TimerTask
      extended by org.apache.s4.core.ft.CheckpointingTask
All Implemented Interfaces:
java.lang.Runnable

public class CheckpointingTask
extends java.util.TimerTask

When checkpointing at regular time intervals, this class is used to actually perform the checkpoints. It iterates among all instances of the specified prototype, and checkpoints every eligible instance.


Constructor Summary
CheckpointingTask(ProcessingElement prototype)
           
 
Method Summary
 void run()
           
 
Methods inherited from class java.util.TimerTask
cancel, scheduledExecutionTime
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CheckpointingTask

public CheckpointingTask(ProcessingElement prototype)
Method Detail

run

public void run()
Specified by:
run in interface java.lang.Runnable
Specified by:
run in class java.util.TimerTask