From 340cdf4670686cd847958425bf8a5f0a253a646e Mon Sep 17 00:00:00 2001 From: Jonathan Ellis Date: Fri, 27 Mar 2009 16:38:34 +0000 Subject: [PATCH] expose concrete serializer git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@759219 13f79535-47bb-0310-9956-ffa450edef68 --- src/org/apache/cassandra/db/Row.java | 10 +++------- src/org/apache/cassandra/db/SuperColumn.java | 10 +++------- 2 files changed, 6 insertions(+), 14 deletions(-) diff --git a/src/org/apache/cassandra/db/Row.java b/src/org/apache/cassandra/db/Row.java index 82da2c9628..0cc6691474 100644 --- a/src/org/apache/cassandra/db/Row.java +++ b/src/org/apache/cassandra/db/Row.java @@ -36,20 +36,16 @@ import org.apache.cassandra.utils.FBUtilities; public class Row { - private static ICompactSerializer serializer_; + private static RowSerializer serializer_ = new RowSerializer(); private static Logger logger_ = Logger.getLogger(Row.class); - static - { - serializer_ = new RowSerializer(); - } - - static ICompactSerializer serializer() + static RowSerializer serializer() { return serializer_; } private String key_; + private Map columnFamilies_ = new Hashtable(); protected Row() diff --git a/src/org/apache/cassandra/db/SuperColumn.java b/src/org/apache/cassandra/db/SuperColumn.java index de1f2309fe..34e597ed16 100644 --- a/src/org/apache/cassandra/db/SuperColumn.java +++ b/src/org/apache/cassandra/db/SuperColumn.java @@ -39,15 +39,10 @@ import org.apache.cassandra.utils.FBUtilities; public final class SuperColumn implements IColumn, Serializable { private static Logger logger_ = Logger.getLogger(SuperColumn.class); - private static ICompactSerializer2 serializer_; + private static SuperColumnSerializer serializer_ = new SuperColumnSerializer(); private final static String seperator_ = ":"; - static - { - serializer_ = new SuperColumnSerializer(); - } - - static ICompactSerializer2 serializer() + static SuperColumnSerializer serializer() { return serializer_; } @@ -173,6 +168,7 @@ public final class SuperColumn implements IColumn, Serializable public byte[] value(String key) { IColumn column = columns_.get(key); + assert column instanceof Column; if ( column != null ) return column.value(); throw new IllegalArgumentException("Value was requested for a column that does not exist.");