voldemort.utils
Class ConsistencyCheck.Reporter

java.lang.Object
  extended by voldemort.utils.ConsistencyCheck.Reporter
Enclosing class:
ConsistencyCheck

protected static class ConsistencyCheck.Reporter
extends java.lang.Object

Used to report bad keys, progress, and statistics


Constructor Summary
ConsistencyCheck.Reporter(java.io.BufferedWriter badKeyWriter)
          Will output progress reports every 5 seconds.
ConsistencyCheck.Reporter(java.io.BufferedWriter badKeyWriter, long intervalMs)
           
 
Method Summary
 void processInconsistentKeys(java.lang.String storeName, java.lang.Integer partitionId, java.util.Map<ByteArray,java.util.Map<Version,java.util.Set<ConsistencyCheck.ClusterNode>>> keyVersionNodeSetMap)
           
 void recordExpired(long count)
           
 void recordGoodKey(long count)
           
 void recordInconsistentKey(long count)
           
 void recordScans(long count)
           
 java.lang.String tryProgressReport()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ConsistencyCheck.Reporter

public ConsistencyCheck.Reporter(java.io.BufferedWriter badKeyWriter)
Will output progress reports every 5 seconds.

Parameters:
badKeyWriter - Writer to which to output bad keys. Null is OK.

ConsistencyCheck.Reporter

public ConsistencyCheck.Reporter(java.io.BufferedWriter badKeyWriter,
                                 long intervalMs)
Parameters:
badKeyWriter - Writer to which to output bad keys. Null is OK.
intervalMs - Milliseconds between progress reports.
Method Detail

recordScans

public void recordScans(long count)

recordExpired

public void recordExpired(long count)

tryProgressReport

public java.lang.String tryProgressReport()

processInconsistentKeys

public void processInconsistentKeys(java.lang.String storeName,
                                    java.lang.Integer partitionId,
                                    java.util.Map<ByteArray,java.util.Map<Version,java.util.Set<ConsistencyCheck.ClusterNode>>> keyVersionNodeSetMap)
                             throws java.io.IOException
Throws:
java.io.IOException

recordGoodKey

public void recordGoodKey(long count)

recordInconsistentKey

public void recordInconsistentKey(long count)


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