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.

Field Summary

Fields inherited from class voldemort.server.storage.DataMaintenanceJob

BLACKLISTED_STORAGE_TYPES, isRunning, iterator, metadataStore, numKeysScannedThisRun, numKeysUpdatedThisRun, scanPermits, STAT_RECORDS_INTERVAL, storeRepo, throttler, totalKeysScanned, totalKeysUpdated

Constructor Summary

RepairJob(StoreRepository storeRepo, MetadataStore metadataStore, ScanPermitWrapper repairPermits, int maxKeysScannedPerSecond)

Method Summary

protected java.lang.String	getJobName()
long	getKeysDeleted()
protected org.apache.log4j.Logger	getLogger()
void	operate()
void	startRepairJob()

Methods inherited from class voldemort.server.storage.DataMaintenanceJob

closeIterator, getIsRunning, getKeysScanned, isWritableStore, resetStats, run

Methods inherited from class java.lang.Object

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

Constructor Detail

RepairJob

public RepairJob(StoreRepository storeRepo,
                 MetadataStore metadataStore,
                 ScanPermitWrapper repairPermits,
                 int maxKeysScannedPerSecond)

Method Detail

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()