Class LoomQueryCache<K,V>

java.lang.Object

com.loomcache.client.query.LoomQueryCache<K,V>

All Implemented Interfaces:

AutoCloseable

public final class LoomQueryCache<K,V>
extends Object
implements AutoCloseable

A continuous-query cache (CQC) that maintains a local materialized view of the cluster entries matching a given predicate.

On creation the cache seeds itself from the cluster via a scan, then receives incremental updates as matching entries are added, changed, or removed. Register CQCListener callbacks to be notified of changes to the view. The view is bounded only by the predicate; close the cache when done to stop receiving updates.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	LoomQueryCache.CQCListener<K,V>
static final record	LoomQueryCache.QueryCacheStatistics

Method Summary

Modifier and Type	Method	Description
void	addListener(LoomQueryCache.CQCListener<K,V> listener)
void	close()
boolean	containsKey(K key)
static <K,V> LoomQueryCache<K,V>	create(LoomClient client, String sourceMapName, BiPredicate<K,V> predicate, Class<K> keyType, Class<V> valueType)
static <K,V> LoomQueryCache<K,V>	create(LoomClient client, String sourceMapName, BiPredicate<K,V> predicate, Class<K> keyType, Class<V> valueType, LoomQueryCacheConfig config)
static <K,V> LoomQueryCache<K,V>	createServerFiltered(LoomClient client, String sourceMapName, SerializablePredicate serverPredicate, Class<K> keyType, Class<V> valueType)
static <K,V> LoomQueryCache<K,V>	createServerFiltered(LoomClient client, String sourceMapName, SerializablePredicate serverPredicate, Class<K> keyType, Class<V> valueType, LoomQueryCacheConfig config)
@Nullable V	get(K key)
LoomQueryCache.QueryCacheStatistics	getStatistics()
boolean	isActive()
boolean	isEmpty()
Set<K>	keySet()
boolean	removeListener(LoomQueryCache.CQCListener<K,V> listener)
int	size()
Map<K,V>	snapshot()
Collection<V>	values()

Methods inherited from class Object

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

Method Details

create

public static <K,V> LoomQueryCache<K,V> create(LoomClient client,
 String sourceMapName,
 BiPredicate<K,V> predicate,
 Class<K> keyType,
 Class<V> valueType)

create

public static <K,V> LoomQueryCache<K,V> create(LoomClient client,
 String sourceMapName,
 BiPredicate<K,V> predicate,
 Class<K> keyType,
 Class<V> valueType,
 LoomQueryCacheConfig config)

createServerFiltered

public static <K,V> LoomQueryCache<K,V> createServerFiltered(LoomClient client,
 String sourceMapName,
 SerializablePredicate serverPredicate,
 Class<K> keyType,
 Class<V> valueType)

createServerFiltered

public static <K,V> LoomQueryCache<K,V> createServerFiltered(LoomClient client,
 String sourceMapName,
 SerializablePredicate serverPredicate,
 Class<K> keyType,
 Class<V> valueType,
 LoomQueryCacheConfig config)

get

public @Nullable V get(K key)

containsKey

public boolean containsKey(K key)

size

public int size()

isEmpty

public boolean isEmpty()

snapshot

public Map<K,V> snapshot()

keySet

public Set<K> keySet()

values

public Collection<V> values()

isActive

public boolean isActive()

addListener

public void addListener(LoomQueryCache.CQCListener<K,V> listener)

removeListener

public boolean removeListener(LoomQueryCache.CQCListener<K,V> listener)

getStatistics

public LoomQueryCache.QueryCacheStatistics getStatistics()

close

public void close()

Specified by:

close in interface AutoCloseable