afeinberg

/**
 * @author afeinberg
 */
public class HintedHandoff {
    private final Cluster cluster;
    private final RoutingStrategy routingStrategy;
    private int lastChosen = -1;

    public HintedHandoff(Cluster cluster, RoutingStrategy routingStrategy) {
        this.cluster = cluster;

afeinberg

diff --git a/src/java/voldemort/store/bdb/BdbStorageEngine.java b/src/java/voldemort/store/bdb/BdbStorageEngine.java
index caa38ca..986a543 100644
--- a/src/java/voldemort/store/bdb/BdbStorageEngine.java
+++ b/src/java/voldemort/store/bdb/BdbStorageEngine.java
@@ -144,12 +144,17 @@ public class BdbStorageEngine implements StorageEngine<ByteArray, byte[]> {
         Cursor cursor = null;
         try {
             cursor = bdbDatabase.openCursor(null, null);
-            return get(cursor, key, lockMode, serializer);
+            List<T> result = get(cursor, key, lockMode, serializer);

afeinberg

(let ((animals '(("cow" . "moo")
		 ("dog" . "arf"))))
  (loop for (animal . sound) in animals do
	(format t "~a says ~a~%" animal sound)))

afeinberg

#include <iostream>
#include <map>
#include <string>

using namespace std;

int main(int argc, char **argv) {
    map<string,string> animals;
    animals["cow"] = "moo";
    animals["dog"] = "arf";

afeinberg

animals = {'cow':'moo', 'dog':'arf' }
for animal,sound in animals.items():
    print animal + " says " + sound

afeinberg

Release 0.60 on 12/15/2009

* Admin Client/Server API: adds support for streaming key/value
  entries, retrieving metadata.
* EC2 testing: a way to periodically run integration and performance
  tests which involve Voldemort instances on different machines
* Experimental support for views
* Interpolation search for read-only stores
* Support for large lists and strings in the JSON serializer
* LZF compression support: 

afeinberg

-Xms384m
-Xmx1200m
-XX:Permsize=384m
-XX:MaxPermsize=384m
-XX:MaxGCPauseMillis=10
–XX:MaxHeapFreeRatio=70
-XX:+UseConcMarkSweepGC
–XX:+CMSIncrementalPacing
-ea

afeinberg

<error message="client routing strategy not in sync with store routing@ strategy!" type="voldemort.store.InvalidMetadataException">voldemort.store.Inv@alidMetadataException: client routing strategy not in sync with store routing s@trategy!
    at java.lang.reflect.Constructor.newInstance(Constructor.java:501)
    at voldemort.utils.ReflectUtils.callConstructor(ReflectUtils.java:117)
    at voldemort.utils.ReflectUtils.callConstructor(ReflectUtils.java:104)
    at voldemort.store.ErrorCodeMapper.getError(ErrorCodeMapper.java:63)
    at voldemort.client.protocol.pb.ProtoBuffClientRequestFormat.throwException(@ProtoBuffClientRequestFormat.java:168)
    at voldemort.client.protocol.pb.ProtoBuffClientRequestFormat.readGetResponse@(ProtoBuffClientRequestFormat.java:103)
    at voldemort.store.socket.SocketStore.get(SocketStore.java:126)
    at voldemort.utils.Ec2RebalancingTest.checkGetEntries(Ec2RebalancingTest.jav@a:349)
    at voldemort.utils.Ec2RebalancingTest.rebalanceAndCheck(Ec2RebalancingTest.j@ava:314)

afeinberg

Exception in thread "main" java.lang.NumberFormatException: For input string: ""
        at java.lang.NumberFormatException.forInputString(NumberFormatException.java:48)
        at java.lang.Integer.parseInt(Integer.java:468)
        at java.lang.Integer.parseInt(Integer.java:497)
        at voldemort.xml.ClusterMapper.readServer(ClusterMapper.java:128)
        at voldemort.xml.ClusterMapper.readCluster(ClusterMapper.java:104)
        at voldemort.store.metadata.MetadataStore.convertStringToObject(MetadataStore.java:368)
        at voldemort.store.metadata.MetadataStore.initCache(MetadataStore.java:147)
        at voldemort.store.metadata.MetadataStore.init(MetadataStore.java:133)
        at voldemort.store.metadata.MetadataStore.<init>(MetadataStore.java:107)