com.hazelcast.internal.eviction

Class ClearExpiredRecordsTask<T>

java.lang.Object

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

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

CacheClearExpiredRecordsTask, MapClearExpiredRecordsTask

public abstract class ClearExpiredRecordsTask<T>
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected int	cleanupOperationCount
protected int	cleanupPercentage
protected T[]	containers
static int	DIFFERENCE_BETWEEN_TWO_SUBSEQUENT_PARTITION_CLEANUP_MILLIS
protected NodeEngine	nodeEngine
protected InternalOperationService	operationService
protected int	taskPeriodSeconds

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected abstract void	clearLeftoverExpiredKeyQueues(T container)
protected abstract Operation	createExpirationOperation(int cleanupPercentage, T container)
int	getCleanupOperationCount()
protected abstract long	getLastCleanupTime(T container)
protected abstract boolean	hasExpiredKeyToSendBackup(T container)
protected abstract boolean	hasRunningCleanup(T container)
protected abstract boolean	isContainerEmpty(T container)
protected abstract boolean	notHaveAnyExpirableRecord(T container)
void	run()
protected void	sendCleanupOperations(List<T> partitionContainers)
protected abstract void	setHasRunningCleanup(T container, boolean status)
protected abstract void	sortPartitionContainers(List<T> containers)

Methods inherited from class java.lang.Object

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

Field Detail

DIFFERENCE_BETWEEN_TWO_SUBSEQUENT_PARTITION_CLEANUP_MILLIS

public static final int DIFFERENCE_BETWEEN_TWO_SUBSEQUENT_PARTITION_CLEANUP_MILLIS

See Also:

Constant Field Values

cleanupOperationCount

protected final int cleanupOperationCount

cleanupPercentage

protected final int cleanupPercentage

taskPeriodSeconds

protected final int taskPeriodSeconds

containers

protected final T[] containers

nodeEngine

protected NodeEngine nodeEngine

operationService

protected InternalOperationService operationService

Constructor Detail

ClearExpiredRecordsTask

public ClearExpiredRecordsTask(NodeEngine nodeEngine,
                               T[] containers,
                               HazelcastProperty cleanupOpProperty,
                               HazelcastProperty cleanupPercentageProperty,
                               HazelcastProperty taskPeriodProperty)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

sendCleanupOperations

protected void sendCleanupOperations(List<T> partitionContainers)

getCleanupOperationCount

public int getCleanupOperationCount()

hasExpiredKeyToSendBackup

protected abstract boolean hasExpiredKeyToSendBackup(T container)

isContainerEmpty

protected abstract boolean isContainerEmpty(T container)

hasRunningCleanup

protected abstract boolean hasRunningCleanup(T container)

setHasRunningCleanup

protected abstract void setHasRunningCleanup(T container,
                                             boolean status)

notHaveAnyExpirableRecord

protected abstract boolean notHaveAnyExpirableRecord(T container)

getLastCleanupTime

protected abstract long getLastCleanupTime(T container)

clearLeftoverExpiredKeyQueues

protected abstract void clearLeftoverExpiredKeyQueues(T container)

sortPartitionContainers

protected abstract void sortPartitionContainers(List<T> containers)

createExpirationOperation

protected abstract Operation createExpirationOperation(int cleanupPercentage,
                                                       T container)