added Values as a default serialization

Nathan Marz · Nathan Marz · commit 161bf2a64b04 · 2012-05-16T20:50:57.000-07:00
diff --git a/src/jvm/backtype/storm/serialization/SerializationFactory.java b/src/jvm/backtype/storm/serialization/SerializationFactory.java
@@ -4,6 +4,7 @@
 import backtype.storm.generated.ComponentCommon;
 import backtype.storm.generated.StormTopology;
 import backtype.storm.transactional.TransactionAttempt;
+import backtype.storm.tuple.Values;
 import backtype.storm.utils.ListDelegate;
 import backtype.storm.utils.Utils;
 import carbonite.JavaBridge;
@@ -52,6 +53,7 @@ public static ObjectBuffer getKryo(Map conf) {
         k.register(HashSet.class);
         k.register(BigInteger.class, new BigIntegerSerializer());
         k.register(TransactionAttempt.class);
+        k.register(Values.class);
         JavaBridge clojureSerializersBridge = new JavaBridge();
         clojureSerializersBridge.registerClojureCollections(k);
         clojureSerializersBridge.registerClojurePrimitives(k);
diff --git a/src/jvm/backtype/storm/tuple/Values.java b/src/jvm/backtype/storm/tuple/Values.java
@@ -7,6 +7,10 @@
  * syntax.
  */
 public class Values extends ArrayList<Object>{
+    public Values() {
+        
+    }
+    
     public Values(Object... vals) {
         super(vals.length);
         for(Object o: vals) {
