org.apache.s4.core.ft
Class SaveStateTask

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

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

Encapsulates a checkpoint request. It is scheduled by the checkpointing framework.


Constructor Summary
SaveStateTask(CheckpointId safeKeeperId, byte[] state, StorageCallback storageCallback, StateStorage stateStorage)
           
SaveStateTask(CheckpointId safeKeeperId, java.util.concurrent.Future<byte[]> futureSerializedState, StorageCallback storageCallback, StateStorage stateStorage)
           
 
Method Summary
 void run()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SaveStateTask

public SaveStateTask(CheckpointId safeKeeperId,
                     byte[] state,
                     StorageCallback storageCallback,
                     StateStorage stateStorage)

SaveStateTask

public SaveStateTask(CheckpointId safeKeeperId,
                     java.util.concurrent.Future<byte[]> futureSerializedState,
                     StorageCallback storageCallback,
                     StateStorage stateStorage)
Method Detail

run

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