Package org.cyclos.impl.utils.cluster

Class HazelcastSharedStorage<K extends Serializable,V extends Serializable>

java.lang.Object

org.cyclos.impl.utils.cluster.HazelcastSharedStorage<K,V>

Type Parameters:

K - The key type

V - The value type

All Implemented Interfaces:

ExpirableStorage<K,V,SerializableBiPredicate<K,V>>, SharedStorage<K,V>, Storage<K,V>

public class HazelcastSharedStorage<K extends Serializable,V extends Serializable>
extends Object
implements SharedStorage<K,V>

A SharedStorage implementation using Hazelcast's IMap

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	HazelcastSharedStorage.HazelcastKeysPredicate<K extends Serializable,V extends Serializable>
static class	HazelcastSharedStorage.HazelcastPredicateDelegate<K extends Serializable,V extends Serializable>

Constructor Summary

Constructors

Constructor	Description
HazelcastSharedStorage(SharedStorageType<K,V> type, com.hazelcast.map.IMap<K,V> map)

Method Summary

Modifier and Type	Method	Description
void	clear()	Removes all keys
V	get(K key)	Returns the value associated with the given key, or null if not present.
Set<K>	keys(SerializableBiPredicate<K,V> test)	Returns all keys that match the given predicate
void	remove(K key)	Removes the given key.
void	removeAll(Collection<K> keys)	Removes all the given keys.
void	removeIf(SerializableBiPredicate<K,V> test)	Removes all the values that matches against the given predicate
void	set(K key, V value)	Adds a value to the store

Methods inherited from class java.lang.Object

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

Constructor Detail

HazelcastSharedStorage

public HazelcastSharedStorage(SharedStorageType<K,V> type,
                              com.hazelcast.map.IMap<K,V> map)

Method Detail

clear

public void clear()

Description copied from interface: Storage

Removes all keys

Specified by:

clear in interface Storage<K extends Serializable,V extends Serializable>

get

public V get(K key)

Description copied from interface: Storage

Returns the value associated with the given key, or null if not present.

Specified by:

get in interface Storage<K extends Serializable,V extends Serializable>

keys

public Set<K> keys(SerializableBiPredicate<K,V> test)

Description copied from interface: ExpirableStorage

Returns all keys that match the given predicate

Specified by:

keys in interface ExpirableStorage<K extends Serializable,V extends Serializable,SerializableBiPredicate<K extends Serializable,V extends Serializable>>

remove

public void remove(K key)

Description copied from interface: Storage

Removes the given key.

Specified by:

remove in interface Storage<K extends Serializable,V extends Serializable>

removeAll

public void removeAll(Collection<K> keys)

Description copied from interface: Storage

Removes all the given keys.

Specified by:

removeAll in interface Storage<K extends Serializable,V extends Serializable>

removeIf

public void removeIf(SerializableBiPredicate<K,V> test)

Description copied from interface: ExpirableStorage

Removes all the values that matches against the given predicate

Specified by:

removeIf in interface ExpirableStorage<K extends Serializable,V extends Serializable,SerializableBiPredicate<K extends Serializable,V extends Serializable>>

set

public void set(K key,
                V value)

Description copied from interface: Storage

Adds a value to the store

Specified by:

set in interface Storage<K extends Serializable,V extends Serializable>