com.hazelcast.map.impl.nearcache

Class BatchInvalidator

java.lang.Object

com.hazelcast.map.impl.nearcache.AbstractNearCacheInvalidator

com.hazelcast.map.impl.nearcache.BatchInvalidator

All Implemented Interfaces:

NearCacheInvalidator

public class BatchInvalidator
extends AbstractNearCacheInvalidator

Sends invalidations to near-caches in batches.

Field Summary

Fields inherited from class com.hazelcast.map.impl.nearcache.AbstractNearCacheInvalidator

clusterService, eventService, mapServiceContext, nearCacheProvider, nodeEngine, operationService

Method Summary

Methods

Modifier and Type	Method and Description
void	accumulateOrInvalidate(String mapName, Data key, List<Data> keys, String sourceUuid)
void	clear(String mapName, boolean owner, String sourceUuid) Clears local and remote near-caches.
void	destroy(String mapName) Removes supplied maps invalidation queue and flushes its content.
static List<Data>	getKeys(BatchNearCacheInvalidation batch)
static List<Data>	getKeysExcludingSource(BatchNearCacheInvalidation batch, String excludedSourceUuid)
void	invalidate(String mapName, Data key, String sourceUuid) Invalidates local and remote near-caches.
void	invalidate(String mapName, List<Data> keys, String sourceUuid) Invalidates local and remote near-caches.
protected void	invalidateMember(BatchNearCacheInvalidation batch)
void	reset() Resets this invalidator back to its initial state.
void	shutdown() Shuts down this invalidator and releases used resources.

Methods inherited from class com.hazelcast.map.impl.nearcache.AbstractNearCacheInvalidator

clearLocal, createSingleOrBatchInvalidationOperation, getOrderKey, hasInvalidationListener, invalidateLocal, isMemberNearCacheInvalidationEnabled, toHeapData

Methods inherited from class java.lang.Object

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

Method Detail

invalidate

public void invalidate(String mapName,
              Data key,
              String sourceUuid)

Description copied from interface: NearCacheInvalidator

Invalidates local and remote near-caches. Local near-caches are node local, remote near-caches can be exist on remote members or clients.

Parameters:

mapName - name of the map.

key - key of the entry to be removed from near-cache.

sourceUuid - caller uuid

invalidate

public void invalidate(String mapName,
              List<Data> keys,
              String sourceUuid)

Description copied from interface: NearCacheInvalidator

Invalidates local and remote near-caches. Local near-caches are node local, remote near-caches can be exist on remote members or clients.

Parameters:

mapName - name of the map.

keys - keys of the entries to be removed from near-cache.

sourceUuid - caller uuid

clear

public void clear(String mapName,
         boolean owner,
         String sourceUuid)

Description copied from interface: NearCacheInvalidator

Clears local and remote near-caches. Local near-caches are node local, remote near-caches can be exist on remote members or clients.

Parameters:

mapName - name of the map.

owner - true if this method is called from partition owner, otherwise false.

sourceUuid - caller uuid

destroy

public void destroy(String mapName)

Description copied from interface: NearCacheInvalidator

Removes supplied maps invalidation queue and flushes its content. This method is called when removing a near-cache with MapRemoteService.destroyDistributedObject(String)

Parameters:

mapName - name of the map.

See Also:

MapRemoteService.destroyDistributedObject(String)

shutdown

public void shutdown()

Description copied from interface: NearCacheInvalidator

Shuts down this invalidator and releases used resources. Aimed to call with ManagedService.shutdown(boolean)

See Also:

com.hazelcast.spi.ManagedService#shutdown(boolean)}

reset

public void reset()

Description copied from interface: NearCacheInvalidator

Resets this invalidator back to its initial state. Aimed to call with ManagedService.reset()

See Also:

ManagedService#reset()}

accumulateOrInvalidate

public void accumulateOrInvalidate(String mapName,
                          Data key,
                          List<Data> keys,
                          String sourceUuid)

invalidateMember

protected void invalidateMember(BatchNearCacheInvalidation batch)

getKeys

public static List<Data> getKeys(BatchNearCacheInvalidation batch)

getKeysExcludingSource

public static List<Data> getKeysExcludingSource(BatchNearCacheInvalidation batch,
                                String excludedSourceUuid)