voldemort.server.scheduler
Class DataCleanupJob<K,V,T>

java.lang.Object
  voldemort.server.scheduler.DataCleanupJob<K,V,T>

All Implemented Interfaces:

java.lang.Runnable

public class DataCleanupJob<K,V,T>
extends java.lang.Object
implements java.lang.Runnable

Expire old data

Constructor Summary

DataCleanupJob(StorageEngine<K,V,T> store, ScanPermitWrapper cleanupPermits, long maxAgeMs, Time time, EventThrottler throttler, MetadataStore metadataStore)

Method Summary

long	getEntriesDeleted()
long	getEntriesScanned()
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

DataCleanupJob

public DataCleanupJob(StorageEngine<K,V,T> store,
                      ScanPermitWrapper cleanupPermits,
                      long maxAgeMs,
                      Time time,
                      EventThrottler throttler,
                      MetadataStore metadataStore)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

getEntriesScanned

public long getEntriesScanned()

getEntriesDeleted

public long getEntriesDeleted()