Package io.deephaven.persistence

Class PersistentHashtable<K,V>

java.lang.Object

io.deephaven.persistence.PersistentHashtable<K,V>

Type Parameters:

K - the table's key class

V - the table's value class

All Implemented Interfaces:

com.fishlib.dataobjects.persistence.PersistentCollection, Persistence.Callbacks<com.fishlib.base.Command>

public class PersistentHashtable<K,V>
extends Object
implements com.fishlib.dataobjects.persistence.PersistentCollection, Persistence.Callbacks<com.fishlib.base.Command>

Implementation of a persistently-stored hash table using the Persistence classes.

Constructor Summary

Constructors

Constructor	Description
PersistentHashtable(String id, PersistencePolicy checkPointPolicy)
PersistentHashtable(String id, PersistencePolicy checkPointPolicy, boolean cleanFileOnError)
PersistentHashtable(String id, PersistencePolicy checkPointPolicy, boolean cleanFileOnError, int size)
PersistentHashtable(String id, PersistencePolicy checkPointPolicy, boolean cleanFileOnError, com.fishlib.dataobjects.WColumnSet[] columnSetsToPersist)
PersistentHashtable(String id, PersistencePolicy checkPointPolicy, com.fishlib.dataobjects.WColumnSet[] columnSetsToPersist)

Method Summary

Modifier and Type	Method	Description
void	clear()
void	commitCheckPoint()
void	disconnect()
void	disconnect(boolean forceCheckpoint)
Set<Map.Entry<K,V>>	entrySet()
V	get(K key)
List<com.fishlib.base.Command>	getCheckPoint()	Called to obtain an atomic (?) snapshot of the contents of the persistent collection in preparation for writing a checkpoint.
void	handlePersistenceInitializationUpdate(Object obj)	Handle an update read from the persistent cache while the persistent collection is being initialized.
Set<K>	keySet()
V	put(K key, V value)
V	putNoPersist(K key, V value)
void	releaseCheckPoint(List<com.fishlib.base.Command> checkpoint)	Called once for every call to getCheckPoint(), to indicate that the persistence implementation is finished with the checkpoint list and the objects contained within it.
V	remove(Object key)
void	setLastCommandId(int cmdId)
Collection<V>	values()

Methods inherited from class java.lang.Object

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

Constructor Details

PersistentHashtable

public PersistentHashtable(String id,
 PersistencePolicy checkPointPolicy)
                    throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

PersistentHashtable

public PersistentHashtable(String id,
 PersistencePolicy checkPointPolicy,
 com.fishlib.dataobjects.WColumnSet[] columnSetsToPersist)
                    throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

PersistentHashtable

public PersistentHashtable(String id,
 PersistencePolicy checkPointPolicy,
 boolean cleanFileOnError)
                    throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

PersistentHashtable

public PersistentHashtable(String id,
 PersistencePolicy checkPointPolicy,
 boolean cleanFileOnError,
 com.fishlib.dataobjects.WColumnSet[] columnSetsToPersist)
                    throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

PersistentHashtable

public PersistentHashtable(String id,
 PersistencePolicy checkPointPolicy,
 boolean cleanFileOnError,
 int size)
                    throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

Method Details

handlePersistenceInitializationUpdate

public void handlePersistenceInitializationUpdate(Object obj)

Description copied from interface: Persistence.Callbacks

Handle an update read from the persistent cache while the persistent collection is being initialized. This should be called *only* during initPersistence().

Specified by:

handlePersistenceInitializationUpdate in interface Persistence.Callbacks<K>

Parameters:

obj - The object just read from the persistent stream.

getCheckPoint

public List<com.fishlib.base.Command> getCheckPoint()

Description copied from interface: Persistence.Callbacks

Called to obtain an atomic (?) snapshot of the contents of the persistent collection in preparation for writing a checkpoint. The persistence policy that the PersistenceImpl was instantiated with controls when checkpoints are written, so this call may come at any time.

Specified by:

getCheckPoint in interface Persistence.Callbacks<K>

Returns:

the list of UpdateType objects (commands) representing the current state of the collection

releaseCheckPoint

public void releaseCheckPoint(List<com.fishlib.base.Command> checkpoint)

Description copied from interface: Persistence.Callbacks

Called once for every call to getCheckPoint(), to indicate that the persistence implementation is finished with the checkpoint list and the objects contained within it.

Specified by:

releaseCheckPoint in interface Persistence.Callbacks<K>

Parameters:

checkpoint - the checkpoint from the getCheckPoint() call

put

public V put(K key,
 V value)
      throws IOException

Throws:

IOException

putNoPersist

public V putNoPersist(K key,
 V value)

remove

public V remove(Object key)
         throws IOException

Throws:

IOException

clear

public void clear()
           throws IOException

Throws:

IOException

entrySet

public Set<Map.Entry<K,V>> entrySet()

keySet

public Set<K> keySet()

values

public Collection<V> values()

get

public V get(K key)

setLastCommandId

public void setLastCommandId(int cmdId)

Specified by:

setLastCommandId in interface com.fishlib.dataobjects.persistence.PersistentCollection

disconnect

public void disconnect()

Specified by:

disconnect in interface com.fishlib.dataobjects.persistence.PersistentCollection

disconnect

public void disconnect(boolean forceCheckpoint)

Specified by:

disconnect in interface com.fishlib.dataobjects.persistence.PersistentCollection

commitCheckPoint

public void commitCheckPoint()
                      throws IOException

Throws:

IOException