You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2010/10/22 23:41:31 UTC

svn commit: r1026502 - /cassandra/trunk/src/java/org/apache/cassandra/io/SerDeUtils.java

Author: brandonwilliams
Date: Fri Oct 22 21:41:31 2010
New Revision: 1026502

URL: http://svn.apache.org/viewvc?rev=1026502&view=rev
Log:
Return correct SpecificDatumReader for schema records.  Patch by Stu Hood, reviewed by brandonwilliams for CASSANDRA-1645.

Modified:
    cassandra/trunk/src/java/org/apache/cassandra/io/SerDeUtils.java

Modified: cassandra/trunk/src/java/org/apache/cassandra/io/SerDeUtils.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/io/SerDeUtils.java?rev=1026502&r1=1026501&r2=1026502&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/io/SerDeUtils.java (original)
+++ cassandra/trunk/src/java/org/apache/cassandra/io/SerDeUtils.java Fri Oct 22 21:41:31 2010
@@ -95,7 +95,7 @@ public final class SerDeUtils
         Schema writer = Schema.parse(dec.readString(new Utf8()).toString());
         SpecificDatumReader<T> reader = new SpecificDatumReader<T>(writer);
         reader.setExpected(ob.getSchema());
-        return new SpecificDatumReader<T>(writer).read(ob, dec);
+        return reader.read(ob, dec);
     }
 
 	/**