com.hazelcast.internal.eviction

Class ClearExpiredRecordsTask<T,S>

java.lang.Object

com.hazelcast.internal.eviction.ClearExpiredRecordsTask<T,S>

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

CacheClearExpiredRecordsTask, MapClearExpiredRecordsTask

public abstract class ClearExpiredRecordsTask<T,S>
extends Object
implements Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	ClearExpiredRecordsTask.ProcessablePartitionType Used when traversing partitions.

Field Summary

Fields

Modifier and Type	Field and Description
protected T[]	containers
protected NodeEngine	nodeEngine
protected IPartitionService	partitionService
protected ToBackupSender<S>	toBackupSender

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ClearExpiredRecordsTask(String serviceName, T[] containers, HazelcastProperty cleanupOpProperty, HazelcastProperty cleanupPercentageProperty, HazelcastProperty taskPeriodProperty, NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
protected abstract void	clearLeftoverExpiredKeyQueues(T container)
protected abstract void	equalizeBackupSizeWithPrimary(T container)
protected abstract long	getLastCleanupTime(T container)
protected abstract ClearExpiredRecordsTask.ProcessablePartitionType	getProcessablePartitionType()
protected abstract boolean	hasExpiredKeyToSendBackup(T container)
protected abstract boolean	hasRunningCleanup(T container)
protected abstract boolean	isContainerEmpty(T container)
protected abstract Operation	newBackupExpiryOp(S store, Collection<ExpiredKey> expiredKeys)
protected IBiFunction<Integer,Integer,Boolean>	newBackupExpiryOpFilter()
protected abstract Operation	newPrimaryExpiryOp(int cleanupPercentage, T container)
protected abstract boolean	notHaveAnyExpirableRecord(T container)
void	partitionLost(PartitionLostEvent ignored) This method increments a counter to count partition lost events.
void	run()
void	sendQueuedExpiredKeys(T container)
void	sendResponse(Operation op, Object response)
protected abstract void	setHasRunningCleanup(T container)
protected abstract void	sortPartitionContainers(List<T> containers)
abstract Iterator<S>	storeIterator(T container)
abstract void	tryToSendBackupExpiryOp(S store, boolean checkIfReachedBatch)

Methods inherited from class java.lang.Object

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

Field Detail

containers

protected final T[] containers

nodeEngine

protected final NodeEngine nodeEngine

toBackupSender

protected final ToBackupSender<S> toBackupSender

partitionService

protected final IPartitionService partitionService

Constructor Detail

ClearExpiredRecordsTask

protected ClearExpiredRecordsTask(String serviceName,
                                  T[] containers,
                                  HazelcastProperty cleanupOpProperty,
                                  HazelcastProperty cleanupPercentageProperty,
                                  HazelcastProperty taskPeriodProperty,
                                  NodeEngine nodeEngine)

Method Detail

newBackupExpiryOpFilter

protected IBiFunction<Integer,Integer,Boolean> newBackupExpiryOpFilter()

run

public void run()

Specified by:

run in interface Runnable

partitionLost

public final void partitionLost(PartitionLostEvent ignored)

This method increments a counter to count partition lost events. After an ungraceful shutdown, backups can have expired entries. And these entries can remain forever on them. Reason for this is, the lost invalidations on a primary partition. During ungraceful shutdown, these invalidations can be lost before sending them to backups. Here, the counter in this method, is used to detect the lost invalidations case. If it is detected, we send expiry operations to remove leftover backup entries. Otherwise leftover entries can remain on backups forever.

sendResponse

public final void sendResponse(Operation op,
                               Object response)

sendQueuedExpiredKeys

public final void sendQueuedExpiredKeys(T container)

isContainerEmpty

protected abstract boolean isContainerEmpty(T container)

hasRunningCleanup

protected abstract boolean hasRunningCleanup(T container)

getLastCleanupTime

protected abstract long getLastCleanupTime(T container)

equalizeBackupSizeWithPrimary

protected abstract void equalizeBackupSizeWithPrimary(T container)

hasExpiredKeyToSendBackup

protected abstract boolean hasExpiredKeyToSendBackup(T container)

notHaveAnyExpirableRecord

protected abstract boolean notHaveAnyExpirableRecord(T container)

clearLeftoverExpiredKeyQueues

protected abstract void clearLeftoverExpiredKeyQueues(T container)

sortPartitionContainers

protected abstract void sortPartitionContainers(List<T> containers)

setHasRunningCleanup

protected abstract void setHasRunningCleanup(T container)

getProcessablePartitionType

protected abstract ClearExpiredRecordsTask.ProcessablePartitionType getProcessablePartitionType()

newPrimaryExpiryOp

protected abstract Operation newPrimaryExpiryOp(int cleanupPercentage,
                                                T container)

newBackupExpiryOp

protected abstract Operation newBackupExpiryOp(S store,
                                               Collection<ExpiredKey> expiredKeys)

tryToSendBackupExpiryOp

public abstract void tryToSendBackupExpiryOp(S store,
                                             boolean checkIfReachedBatch)

storeIterator

public abstract Iterator<S> storeIterator(T container)