edu.iu.dsc.tws.checkpointing.util

Class CheckpointUtils

java.lang.Object

edu.iu.dsc.tws.checkpointing.util.CheckpointUtils

public final class CheckpointUtils
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static void	commitState(StateStore stateStore, java.lang.String family, int componentIndex, SnapshotImpl snapshot, CheckpointingClient checkpointingClient, MessageHandler messageHandler)
static boolean	containsJobInStore(java.lang.String jobId, StateStore stateStore)
static StateStore	getStateStore(Config config)
static byte[]	restoreJobConfig(java.lang.String jobId, StateStore stateStore)
static byte[]	restoreJobMeta(java.lang.String jobId, StateStore stateStore)
static void	restoreSnapshot(StateStore stateStore, java.lang.Long version, SnapshotImpl snapshot)
static void	saveJobConfigAndMeta(java.lang.String jobId, byte[] jobMeta, byte[] jobConfig, StateStore stateStore)
static void	saveState(StateStore stateStore, SnapshotImpl snapshot)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

commitState

public static void commitState(StateStore stateStore,
                               java.lang.String family,
                               int componentIndex,
                               SnapshotImpl snapshot,
                               CheckpointingClient checkpointingClient,
                               MessageHandler messageHandler)
                        throws java.io.IOException

Throws:

java.io.IOException

saveState

public static void saveState(StateStore stateStore,
                             SnapshotImpl snapshot)
                      throws java.io.IOException

Throws:

java.io.IOException

restoreSnapshot

public static void restoreSnapshot(StateStore stateStore,
                                   java.lang.Long version,
                                   SnapshotImpl snapshot)
                            throws java.io.IOException

Throws:

java.io.IOException

getStateStore

public static StateStore getStateStore(Config config)

saveJobConfigAndMeta

public static void saveJobConfigAndMeta(java.lang.String jobId,
                                        byte[] jobMeta,
                                        byte[] jobConfig,
                                        StateStore stateStore)
                                 throws java.io.IOException

Throws:

java.io.IOException

restoreJobConfig

public static byte[] restoreJobConfig(java.lang.String jobId,
                                      StateStore stateStore)
                               throws java.io.IOException

Throws:

java.io.IOException

restoreJobMeta

public static byte[] restoreJobMeta(java.lang.String jobId,
                                    StateStore stateStore)
                             throws java.io.IOException

Throws:

java.io.IOException

containsJobInStore

public static boolean containsJobInStore(java.lang.String jobId,
                                         StateStore stateStore)
                                  throws java.io.IOException

Throws:

java.io.IOException