edu.iu.dsc.tws.tset.env

Class BatchChkPntEnvironment

java.lang.Object

edu.iu.dsc.tws.tset.env.TSetEnvironment

edu.iu.dsc.tws.tset.env.BatchEnvironment

edu.iu.dsc.tws.tset.env.BatchChkPntEnvironment

public class BatchChkPntEnvironment
extends BatchEnvironment

Extension to the BatchEnvironment with checkpointing capability.

Constructor Summary

Constructors

Constructor and Description
BatchChkPntEnvironment(WorkerEnvironment workerEnvironment)

Method Summary

Modifier and Type	Method and Description
void	commit() Commits the snapshot
<T> T	initVariable(java.lang.String name, T defaultValue) Initialize a variable from previous snapshot.
<T> T	updateVariable(java.lang.String name, T value) Updates the variable in the snapshot

Methods inherited from class edu.iu.dsc.tws.tset.env.BatchEnvironment

createArrowSource, createArrowSource, createCSVSource, createHadoopSource, createHadoopSource, createKeyedHadoopSource, createKeyedSource, createKeyedSource, createRowSource, createSource, createSource, createTextSource, eval, evalAndUpdate, finishEval, getData, getOperationMode, run, runAndUpdate, runOne

Methods inherited from class edu.iu.dsc.tws.tset.env.TSetEnvironment

addInput, close, executeBuildContext, getConfig, getDefaultParallelism, getGraph, getInputs, getNoOfWorkers, getTaskExecutor, getTSetGraph, getWorkerEnv, getWorkerID, initBatch, initCheckpointing, initStreaming, isCheckpointingEnabled, parallelize, parallelize, parallelize, parallelize, setDefaultParallelism, settBaseGraph

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchChkPntEnvironment

public BatchChkPntEnvironment(WorkerEnvironment workerEnvironment)

Method Detail

updateVariable

public <T> T updateVariable(java.lang.String name,
                            T value)

Updates the variable in the snapshot

initVariable

public <T> T initVariable(java.lang.String name,
                          T defaultValue)

Initialize a variable from previous snapshot. Use default value if this variable is not defined in previous snapshot

commit

public void commit()

Commits the snapshot