You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2011/06/24 05:22:33 UTC
svn commit: r1139147 - /cassandra/trunk/src/java/org/apache/cassandra/db/Row.java

Author: jbellis
Date: Fri Jun 24 03:22:33 2011
New Revision: 1139147

URL: http://svn.apache.org/viewvc?rev=1139147&view=rev
Log:
move RowSerializer to static inner class

Modified:
    cassandra/trunk/src/java/org/apache/cassandra/db/Row.java

Modified: cassandra/trunk/src/java/org/apache/cassandra/db/Row.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/db/Row.java?rev=1139147&r1=1139146&r2=1139147&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/db/Row.java (original)
+++ cassandra/trunk/src/java/org/apache/cassandra/db/Row.java Fri Jun 24 03:22:33 2011
@@ -54,24 +54,24 @@ public class Row
                ", cf=" + cf +
                ')';
     }
-}
 
-class RowSerializer implements ICompactSerializer<Row>
-{
-    public void serialize(Row row, DataOutputStream dos, int version) throws IOException
+    public static class RowSerializer implements ICompactSerializer<Row>
     {
-        ByteBufferUtil.writeWithShortLength(row.key.key, dos);
-        ColumnFamily.serializer().serialize(row.cf, dos);
-    }
+        public void serialize(Row row, DataOutputStream dos, int version) throws IOException
+        {
+            ByteBufferUtil.writeWithShortLength(row.key.key, dos);
+            ColumnFamily.serializer().serialize(row.cf, dos);
+        }
 
-    public Row deserialize(DataInputStream dis, int version, boolean fromRemote) throws IOException
-    {
-        return new Row(StorageService.getPartitioner().decorateKey(ByteBufferUtil.readWithShortLength(dis)),
-                       ColumnFamily.serializer().deserialize(dis, false, fromRemote));
-    }
+        public Row deserialize(DataInputStream dis, int version, boolean fromRemote) throws IOException
+        {
+            return new Row(StorageService.getPartitioner().decorateKey(ByteBufferUtil.readWithShortLength(dis)),
+                           ColumnFamily.serializer().deserialize(dis, false, fromRemote));
+        }
 
-    public Row deserialize(DataInputStream dis, int version) throws IOException
-    {
-        return deserialize(dis, version, false);
+        public Row deserialize(DataInputStream dis, int version) throws IOException
+        {
+            return deserialize(dis, version, false);
+        }
     }
-}
+}
\ No newline at end of file