voldemort.utils
Class ConsistencyCheck.KeyFetchTracker

java.lang.Object
  voldemort.utils.ConsistencyCheck.KeyFetchTracker

Enclosing class:

ConsistencyCheck

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

A class to track what keys have been fetched and what keys will not appear any more. It is used to detect keys that will not show up any more so that existing versions can be processed.

Constructor Summary

ConsistencyCheck.KeyFetchTracker(java.lang.Integer fetcherCount)

Method Summary

void	finishAll() mark all keys appeared as finished So that they are all in the finished keys queue
ByteArray	nextFinished() Get a key that are completed in fetching
void	recordFetch(ConsistencyCheck.ClusterNode clusterNode, ByteArray key) Record a fetched result

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsistencyCheck.KeyFetchTracker

public ConsistencyCheck.KeyFetchTracker(java.lang.Integer fetcherCount)

Method Detail

recordFetch

public void recordFetch(ConsistencyCheck.ClusterNode clusterNode,
                        ByteArray key)

Record a fetched result

Parameters:

clusterNode - The clusterNode from which the key has been fetched

key - The key itself

finishAll

public void finishAll()

mark all keys appeared as finished So that they are all in the finished keys queue

nextFinished

public ByteArray nextFinished()

Get a key that are completed in fetching

Returns:

key considered finished; otherwise null