edu.iu.dsc.tws.checkpointing.task

Interface CheckpointableTask

All Known Implementing Classes:

CheckpointingTaskExample.ComputeTask, CheckpointingTaskExample.SinkTask, CheckpointingTaskExample.SourceTask, KafkaExample.KSink, KafkaExample.KSource, KafkaSource

public interface CheckpointableTask

Method Summary

Modifier and Type	Method and Description
void	initSnapshot(Snapshot snapshot) This method could be used to predefine packers
default void	onCheckpointPropagated(Snapshot snapshot) This method will be called immediately after task report it's version to the checkpoint master
default void	onSnapshotPersisted(Snapshot snapshot) This method will be called when task persist it's local state to the store
void	restoreSnapshot(Snapshot snapshot) This method will be called when task is initializing
void	takeSnapshot(Snapshot snapshot) Snapshot should be updated in this method with new values

Method Detail

restoreSnapshot

void restoreSnapshot(Snapshot snapshot)

This method will be called when task is initializing

takeSnapshot

void takeSnapshot(Snapshot snapshot)

Snapshot should be updated in this method with new values

initSnapshot

void initSnapshot(Snapshot snapshot)

This method could be used to predefine packers

onSnapshotPersisted

default void onSnapshotPersisted(Snapshot snapshot)

This method will be called when task persist it's local state to the store

onCheckpointPropagated

default void onCheckpointPropagated(Snapshot snapshot)

This method will be called immediately after task report it's version to the checkpoint master