voldemort.server.storage.repairjob
Class RepairJob
java.lang.Object
voldemort.server.storage.DataMaintenanceJob
voldemort.server.storage.repairjob.RepairJob
- All Implemented Interfaces:
- java.lang.Runnable
public class RepairJob
- extends DataMaintenanceJob
This is a background job that should be run after successful rebalancing. The
job deletes all data that does not belong to the server.
FIXME VC RepairJob is a non intuitive name. Need to rename this.
Fields inherited from class voldemort.server.storage.DataMaintenanceJob |
BLACKLISTED_STORAGE_TYPES, isRunning, iterator, metadataStore, numKeysScannedThisRun, numKeysUpdatedThisRun, scanPermits, STAT_RECORDS_INTERVAL, storeRepo, throttler, totalKeysScanned, totalKeysUpdated |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RepairJob
public RepairJob(StoreRepository storeRepo,
MetadataStore metadataStore,
ScanPermitWrapper repairPermits,
int maxKeysScannedPerSecond)
startRepairJob
public void startRepairJob()
operate
public void operate()
throws java.lang.Exception
- Specified by:
operate
in class DataMaintenanceJob
- Throws:
java.lang.Exception
getLogger
protected org.apache.log4j.Logger getLogger()
- Specified by:
getLogger
in class DataMaintenanceJob
getJobName
protected java.lang.String getJobName()
- Specified by:
getJobName
in class DataMaintenanceJob
getKeysDeleted
public long getKeysDeleted()
Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu