voldemort.utils
Class ConsistencyCheck.Reporter

java.lang.Object
  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.Writer badKeyWriter)
Will output progress reports every 5 seconds.

ConsistencyCheck.Reporter(java.io.Writer badKeyWriter, long intervalMs)

Method Summary

void	processInconsistentKeys(java.lang.String storeName, java.lang.Integer partitionId, java.util.Map<ByteArray,java.util.Map<ConsistencyCheck.Value,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.Writer 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.Writer 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<ConsistencyCheck.Value,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)