voldemort.utils
Class ConsistencyFix

java.lang.Object
  extended by voldemort.utils.ConsistencyFix

public class ConsistencyFix
extends java.lang.Object


Nested Class Summary
static class ConsistencyFix.BadKey
          Type with which to wrap a "bad key"
static class ConsistencyFix.BadKeyOrphanReader
           
static class ConsistencyFix.BadKeyReader
           
static class ConsistencyFix.BadKeyStatus
          Type with which to wrap a "bad key" that could not be repaired and so needs to be written to output file.
static class ConsistencyFix.BadKeyWriter
           
static class ConsistencyFix.Stats
           
static class ConsistencyFix.Status
          Status of the repair of a specific "bad key"
 
Method Summary
 void close()
           
 java.lang.String execute(int parallelism, java.lang.String badKeyFileIn, boolean orphanFormat, java.lang.String badKeyFileOut)
           
 AdminClient getAdminClient()
           
 ConsistencyFix.Stats getStats()
           
 StoreRoutingPlan getStoreInstance()
           
 java.lang.String getStoreName()
           
 boolean isDryRun()
           
 boolean isParseOnly()
           
 void maybePutThrottle(int nodeId)
          Throttle put (repair) activity per server.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getStoreName

public java.lang.String getStoreName()

getStoreInstance

public StoreRoutingPlan getStoreInstance()

getAdminClient

public AdminClient getAdminClient()

close

public void close()

getStats

public ConsistencyFix.Stats getStats()

isDryRun

public boolean isDryRun()

isParseOnly

public boolean isParseOnly()

maybePutThrottle

public void maybePutThrottle(int nodeId)
Throttle put (repair) activity per server.

Parameters:
nodeId - The node for which to possibly throttle put activity.

execute

public java.lang.String execute(int parallelism,
                                java.lang.String badKeyFileIn,
                                boolean orphanFormat,
                                java.lang.String badKeyFileOut)


Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu