com.hazelcast.map.impl.querycache.subscriber

Interface InternalQueryCache<K,V>

Type Parameters:

K - the key type for this QueryCache

V - the value type for this QueryCache

All Superinterfaces:

QueryCache<K,V>

All Known Implementing Classes:

NullQueryCache

public interface InternalQueryCache<K,V>
extends QueryCache<K,V>

Internal interface which adds some internally used methods to QueryCache interface.

Method Summary

Modifier and Type	Method and Description
void	clear()
void	delete(Object key, EntryEventType eventType)
String	getCacheId()
IMap<K,V>	getDelegate()
Extractors	getExtractors()
Indexes	getIndexes()
String	getPublisherListenerId()
void	prepopulate(K key, V value) Used during initial population of query cache.
boolean	reachedMaxCapacity() Used to quit pre-population when max size is reached.
void	recreate() Recreates this query cache.
int	removeEntriesOf(int partitionId) Scans all entries in this QueryCache to remove matching ones with supplied partitionId
void	set(K key, V value, EntryEventType eventType)
void	setPublisherListenerId(String publisherListenerId)

Methods inherited from interface com.hazelcast.map.QueryCache

addEntryListener, addEntryListener, addEntryListener, addEntryListener, addIndex, containsKey, containsValue, destroy, entrySet, entrySet, get, getAll, getName, isEmpty, keySet, keySet, removeEntryListener, size, tryRecover, values, values

Method Detail

set

void set(K key,
         V value,
         EntryEventType eventType)

prepopulate

void prepopulate(K key,
                 V value)

Used during initial population of query cache. Initially fetched data from cluster will be written to query cache by the help of this method.

delete

void delete(Object key,
            EntryEventType eventType)

removeEntriesOf

int removeEntriesOf(int partitionId)

Scans all entries in this QueryCache to remove matching ones with supplied partitionId

Returns:

number of entries removed

getDelegate

IMap<K,V> getDelegate()

getIndexes

Indexes getIndexes()

clear

void clear()

setPublisherListenerId

void setPublisherListenerId(String publisherListenerId)

getPublisherListenerId

String getPublisherListenerId()

getCacheId

String getCacheId()

Returns:

internally used ID for this query cache

reachedMaxCapacity

boolean reachedMaxCapacity()

Used to quit pre-population when max size is reached.

Returns:

true if this query cache is at its max capacity, otherwise return false

See Also:

QueryCacheConfig.isPopulate()

getExtractors

Extractors getExtractors()

Returns:

extractors of this query cache instance.

recreate

void recreate()

Recreates this query cache. Recreation steps are:

• Reset local subscribers' state, clear all cache entries so far.
• Recreate/reset publisher (server) side resources by using this subscribers'metadata e.g. on server restart we can recreate server side resources.