Package com.tnsai.state

Class InMemoryCheckpointer

java.lang.Object

com.tnsai.state.InMemoryCheckpointer

All Implemented Interfaces:

Checkpointer

public class InMemoryCheckpointer
extends Object
implements Checkpointer

In-Memory Checkpointer - For development/testing.

Nested Class Summary

Nested classes/interfaces inherited from interface com.tnsai.state.Checkpointer

Checkpointer.CheckpointTuple, Checkpointer.Write

Constructor Summary

Constructors

Constructor	Description
InMemoryCheckpointer()

Method Summary

Modifier and Type	Method	Description
void	clear()	Clear all checkpoints.
void	delete(String threadId)	Delete checkpoints for a thread.
int	getCheckpointCount()	Get checkpoint count.
Checkpointer.CheckpointTuple	getTuple(String threadId, String checkpointId)	Fetch a checkpoint.
List<Checkpointer.CheckpointTuple>	list(String threadId)	List checkpoints for a thread.
void	put(String threadId, String checkpointId, Map<String,Object> state, Map<String,Object> metadata)	Store a checkpoint.
void	putWrites(String checkpointId, List<Checkpointer.Write> writeList)	Store intermediate writes.

Methods inherited from class java.lang.Object

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

Constructor Details

InMemoryCheckpointer

public InMemoryCheckpointer()

Method Details

put

public void put(String threadId,
 String checkpointId,
 Map<String,Object> state,
 Map<String,Object> metadata)

Description copied from interface: Checkpointer

Store a checkpoint.

Specified by:

put in interface Checkpointer

Parameters:

threadId - Thread identifier

checkpointId - Checkpoint identifier

state - State data

metadata - Checkpoint metadata

putWrites

public void putWrites(String checkpointId,
 List<Checkpointer.Write> writeList)

Description copied from interface: Checkpointer

Store intermediate writes.

Specified by:

putWrites in interface Checkpointer

Parameters:

checkpointId - Checkpoint identifier

writeList - List of writes

getTuple

public Checkpointer.CheckpointTuple getTuple(String threadId,
 String checkpointId)

Description copied from interface: Checkpointer

Fetch a checkpoint.

Specified by:

getTuple in interface Checkpointer

Parameters:

threadId - Thread identifier

checkpointId - Checkpoint identifier (null for latest)

Returns:

Checkpoint tuple

list

public List<Checkpointer.CheckpointTuple> list(String threadId)

Description copied from interface: Checkpointer

List checkpoints for a thread.

Specified by:

list in interface Checkpointer

Parameters:

threadId - Thread identifier

Returns:

List of checkpoints

delete

public void delete(String threadId)

Description copied from interface: Checkpointer

Delete checkpoints for a thread.

Specified by:

delete in interface Checkpointer

Parameters:

threadId - Thread identifier

clear

public void clear()

Clear all checkpoints.

getCheckpointCount

public int getCheckpointCount()

Get checkpoint count.