public class BatchInvalidator extends AbstractNearCacheInvalidator
clusterService, eventService, mapServiceContext, nearCacheProvider, nodeEngine, operationService
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.
|
clearLocal, createSingleOrBatchInvalidationOperation, getOrderKey, hasInvalidationListener, invalidateLocal, isMemberNearCacheInvalidationEnabled, toHeapData
public void invalidate(String mapName, Data key, String sourceUuid)
NearCacheInvalidator
mapName
- name of the map.key
- key of the entry to be removed from near-cache.sourceUuid
- caller uuidpublic void invalidate(String mapName, List<Data> keys, String sourceUuid)
NearCacheInvalidator
mapName
- name of the map.keys
- keys of the entries to be removed from near-cache.sourceUuid
- caller uuidpublic void clear(String mapName, boolean owner, String sourceUuid)
NearCacheInvalidator
mapName
- name of the map.owner
- true
if this method is called from partition owner, otherwise false
.sourceUuid
- caller uuidpublic void destroy(String mapName)
NearCacheInvalidator
MapRemoteService.destroyDistributedObject(String)
mapName
- name of the map.MapRemoteService.destroyDistributedObject(String)
public void shutdown()
NearCacheInvalidator
ManagedService.shutdown(boolean)
com.hazelcast.spi.ManagedService#shutdown(boolean)}
public void reset()
NearCacheInvalidator
ManagedService.reset()
ManagedService#reset()}
public void accumulateOrInvalidate(String mapName, Data key, List<Data> keys, String sourceUuid)
protected void invalidateMember(BatchNearCacheInvalidation batch)
public static List<Data> getKeys(BatchNearCacheInvalidation batch)
public static List<Data> getKeysExcludingSource(BatchNearCacheInvalidation batch, String excludedSourceUuid)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.