com.hazelcast.internal.nearcache.impl.invalidation

Class BatchInvalidator

java.lang.Object

com.hazelcast.internal.nearcache.impl.invalidation.Invalidator

com.hazelcast.internal.nearcache.impl.invalidation.BatchInvalidator

public class BatchInvalidator
extends Invalidator

Sends invalidations to Near Cache in batches.

Field Summary

Fields inherited from class com.hazelcast.internal.nearcache.impl.invalidation.Invalidator

eventFilter, eventService, logger, metaDataGenerator, nodeEngine, partitionCount, partitionService, serviceName

Constructor Summary

Constructors

Constructor and Description
BatchInvalidator(String serviceName, int batchSize, int batchFrequencySeconds, IFunction<EventRegistration,Boolean> eventFilter, NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
void	destroy(String dataStructureName, String sourceUuid) Removes supplied data structures invalidation queues and flushes their content.
protected void	invalidateInternal(Invalidation invalidation, int orderKey)
protected Invalidation	newInvalidation(Data key, String dataStructureName, String sourceUuid, int partitionId)
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.internal.nearcache.impl.invalidation.Invalidator

getMetaDataGenerator, invalidateAllKeys, invalidateKey, resetPartitionMetaData, sendImmediately

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchInvalidator

public BatchInvalidator(String serviceName,
                        int batchSize,
                        int batchFrequencySeconds,
                        IFunction<EventRegistration,Boolean> eventFilter,
                        NodeEngine nodeEngine)

Method Detail

newInvalidation

protected Invalidation newInvalidation(Data key,
                                       String dataStructureName,
                                       String sourceUuid,
                                       int partitionId)

Overrides:

newInvalidation in class Invalidator

invalidateInternal

protected void invalidateInternal(Invalidation invalidation,
                                  int orderKey)

Specified by:

invalidateInternal in class Invalidator

destroy

public void destroy(String dataStructureName,
                    String sourceUuid)

Description copied from class: Invalidator

Removes supplied data structures invalidation queues and flushes their content. This method is called when removing a Near Cache for example with MapRemoteService.destroyDistributedObject(String)

Overrides:

destroy in class Invalidator

Parameters:

dataStructureName - name of the data structure.

See Also:

MapRemoteService.destroyDistributedObject(String)

shutdown

public void shutdown()

Description copied from class: Invalidator

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

Overrides:

shutdown in class Invalidator

See Also:

ManagedService.shutdown(boolean)

reset

public void reset()

Description copied from class: Invalidator

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

Overrides:

reset in class Invalidator

See Also:

ManagedService.reset()