edu.iu.dsc.tws.executor.core

Class TaskCheckpointUtils

java.lang.Object

edu.iu.dsc.tws.executor.core.TaskCheckpointUtils

public final class TaskCheckpointUtils
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static void	checkpoint(long checkpointID, CheckpointableTask checkpointableTask, SnapshotImpl snapshot, StateStore stateStore, java.lang.String family, int globalTaskId, CheckpointingClient checkpointingClient)
static void	restore(CheckpointableTask checkpointableTask, SnapshotImpl snapshot, StateStore stateStore, long tasksVersion, int globalTaskId)

Methods inherited from class java.lang.Object

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

Method Detail

restore

public static void restore(CheckpointableTask checkpointableTask,
                           SnapshotImpl snapshot,
                           StateStore stateStore,
                           long tasksVersion,
                           int globalTaskId)

checkpoint

public static void checkpoint(long checkpointID,
                              CheckpointableTask checkpointableTask,
                              SnapshotImpl snapshot,
                              StateStore stateStore,
                              java.lang.String family,
                              int globalTaskId,
                              CheckpointingClient checkpointingClient)