edu.iu.dsc.tws.checkpointing.api

Class SnapshotImpl

java.lang.Object

edu.iu.dsc.tws.checkpointing.api.SnapshotImpl

All Implemented Interfaces:

Snapshot

public class SnapshotImpl
extends java.lang.Object
implements Snapshot

This class implements Snapshot and will have some additional methods to manipulate version and pack and unpack snapshot.User interfacing methods should always accept Snapshot interface which doesn't contain those additional methods.

Constructor Summary

Constructors

Constructor and Description
SnapshotImpl()

Method Summary

Modifier and Type	Method and Description
boolean	checkpointAvailable(java.lang.String key) Weater a checkpoint available for a kye
SnapshotImpl	copy()
boolean	equals(java.lang.Object o)
java.lang.Object	get(java.lang.String key) Get the value for a key
java.lang.Object	getOrDefault(java.lang.String key, java.lang.Object defaultValue) Get the value for key or the default
long	getVersion() Returns the current version of the snapshot
int	hashCode()
byte[]	pack()
void	setPacker(java.lang.String key, DataPacker dataPacker) This method can be used to define packers.
void	setValue(java.lang.String key, java.lang.Object value) This method can be used to set/update values into the snapshot
void	setVersion(long version)
void	unpack(byte[] bytes)

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.iu.dsc.tws.api.checkpointing.Snapshot

setValue

Constructor Detail

SnapshotImpl

public SnapshotImpl()

Method Detail

setPacker

public void setPacker(java.lang.String key,
                      DataPacker dataPacker)

Description copied from interface: Snapshot

This method can be used to define packers. Packers will be used when deserializing values. If packer is not defined for a particular value, that value will be treated as an Object and serialized with ObjectPacker

Specified by:

setPacker in interface Snapshot

Parameters:

key - key

dataPacker - the data packer to use for the key

setValue

public void setValue(java.lang.String key,
                     java.lang.Object value)

Description copied from interface: Snapshot

This method can be used to set/update values into the snapshot

Specified by:

setValue in interface Snapshot

Parameters:

key - key

value - value to add

getVersion

public long getVersion()

Description copied from interface: Snapshot

Returns the current version of the snapshot

Specified by:

getVersion in interface Snapshot

checkpointAvailable

public boolean checkpointAvailable(java.lang.String key)

Description copied from interface: Snapshot

Weater a checkpoint available for a kye

Specified by:

checkpointAvailable in interface Snapshot

Parameters:

key - key

Returns:

true if a key is available

setVersion

public void setVersion(long version)

getOrDefault

public java.lang.Object getOrDefault(java.lang.String key,
                                     java.lang.Object defaultValue)

Description copied from interface: Snapshot

Get the value for key or the default

Specified by:

getOrDefault in interface Snapshot

Parameters:

key - key

defaultValue - default value

Returns:

value corresponding to key

get

public java.lang.Object get(java.lang.String key)

Description copied from interface: Snapshot

Get the value for a key

Specified by:

get in interface Snapshot

Parameters:

key - key

Returns:

value

pack

public byte[] pack()

unpack

public void unpack(byte[] bytes)

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

copy

public SnapshotImpl copy()