Permalink
Browse files

Adding @deprecated for proxy put param + cosmetic debug msg fixes

  • Loading branch information...
vinothchandar committed Apr 22, 2013
1 parent 881d7b3 commit 736ccc8087335c2c40abf2b02db46f248af79c6e
@@ -223,6 +223,8 @@
private int maxParallelStoresRebalancing;
private boolean rebalancingOptimization;
private boolean usePartitionScanForRebalance;
+ @Deprecated
+ // Should be removed once the proxy put implementation is stable.
private boolean proxyPutsDuringRebalance;
public VoldemortConfig(Properties props) {
@@ -38,7 +38,7 @@ public void transfer() throws Exception {
while(cursor.getNext(keyEntry, valueEntry, LockMode.READ_UNCOMMITTED) == OperationStatus.SUCCESS) {
scanCount++;
if(scanCount % 1000000 == 0)
- logger.info("Converted " + scanCount + "entries in "
+ logger.info("Converted " + scanCount + " entries in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
// read the value as a versioned Object
@@ -80,7 +80,7 @@ public void transfer() throws Exception {
}
keyCount++;
}
- logger.info("Completed " + scanCount + "entries and " + keyCount + " keys in "
+ logger.info("Completed " + scanCount + " entries and " + keyCount + " keys in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}
@@ -42,7 +42,7 @@ public void transfer() throws Exception {
while(cursor.getNext(keyEntry, valueEntry, LockMode.READ_UNCOMMITTED) == OperationStatus.SUCCESS) {
scanCount++;
if(scanCount % 1000000 == 0)
- logger.info("Converted " + scanCount + "entries in "
+ logger.info("Converted " + scanCount + " entries in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
// read the value as a versioned Object
@@ -90,7 +90,7 @@ public void transfer() throws Exception {
}
keyCount++;
}
- logger.info("Completed " + scanCount + "entries and " + keyCount + " keys in "
+ logger.info("Completed " + scanCount + " entries and " + keyCount + " keys in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}
@@ -55,10 +55,10 @@ public void transfer() throws Exception {
}
if(scanCount % 1000000 == 0)
- logger.info("Reverted " + scanCount + "entries in "
+ logger.info("Reverted " + scanCount + " entries in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}
- logger.info("Converted " + scanCount + "entries and " + keyCount + " keys in "
+ logger.info("Converted " + scanCount + " entries and " + keyCount + " keys in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}
@@ -52,10 +52,10 @@ public void transfer() throws Exception {
scanCount++;
}
if(scanCount % 1000000 == 0)
- logger.info("Reverted " + scanCount + "entries in "
+ logger.info("Reverted " + scanCount + " entries in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}
- logger.info("Reverted " + scanCount + "entries and " + keyCount + " keys in "
+ logger.info("Reverted " + scanCount + " entries and " + keyCount + " keys in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}
@@ -54,10 +54,10 @@ public void transfer() throws Exception {
scanCount++;
}
if(scanCount % 1000000 == 0)
- logger.info("Reverted " + scanCount + "entries in "
+ logger.info("Reverted " + scanCount + " entries in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}
- logger.info("Reverted " + scanCount + "entries and " + keyCount + " keys in "
+ logger.info("Reverted " + scanCount + " entries and " + keyCount + " keys in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}
@@ -47,10 +47,10 @@ public void transfer() throws Exception {
}
if(scanCount % 1000000 == 0)
- logger.info("Reverted " + scanCount + "entries in "
+ logger.info("Reverted " + scanCount + " entries in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}
- logger.info("Reverted " + scanCount + "entries and " + keyCount + " keys in "
+ logger.info("Reverted " + scanCount + " entries and " + keyCount + " keys in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}

0 comments on commit 736ccc8

Please sign in to comment.