com.hazelcast.internal.eviction

Class ExpirationManager

java.lang.Object

com.hazelcast.internal.eviction.ExpirationManager

All Implemented Interfaces:

LifecycleListener, PartitionLostListener, EventListener

public final class ExpirationManager
extends Object
implements LifecycleListener, PartitionLostListener

This class is responsible for gradual cleanup of expired entries from IMap and ICache. For this purpose it uses a background task. Gradual cleanup is in place for IMap since 3.3 and ICache since 3.11

Constructor Summary

Constructors

Constructor and Description
ExpirationManager(ClearExpiredRecordsTask task, NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
protected HazelcastInstance	getHazelcastInstance()
ClearExpiredRecordsTask	getTask()
void	onClusterStateChange(ClusterState newState)
void	onShutdown() Called upon shutdown of MapService
void	partitionLost(PartitionLostEvent event) Invoked when a partition loses its owner and all backups.
void	scheduleExpirationTask() Starts scheduling of the task that clears expired entries.
void	stateChanged(LifecycleEvent event) Called when instance's state changes.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExpirationManager

public ExpirationManager(ClearExpiredRecordsTask task,
                         NodeEngine nodeEngine)

Method Detail

getHazelcastInstance

protected HazelcastInstance getHazelcastInstance()

scheduleExpirationTask

public void scheduleExpirationTask()

Starts scheduling of the task that clears expired entries. Calling this method multiple times has same effect.

stateChanged

public void stateChanged(LifecycleEvent event)

Description copied from interface: LifecycleListener

Called when instance's state changes. No blocking calls should be made in this method.

Specified by:

stateChanged in interface LifecycleListener

Parameters:

event - the Lifecycle event

partitionLost

public void partitionLost(PartitionLostEvent event)

Description copied from interface: PartitionLostListener

Invoked when a partition loses its owner and all backups.

Specified by:

partitionLost in interface PartitionLostListener

Parameters:

event - the event that contains the partition ID and the backup count that has been lost

onClusterStateChange

public void onClusterStateChange(ClusterState newState)

onShutdown

public void onShutdown()

Called upon shutdown of MapService

getTask

public ClearExpiredRecordsTask getTask()