Author: jbellis
Date: Thu Jul 14 05:49:37 2011
New Revision: 1146569

URL: http://svn.apache.org/viewvc?rev=1146569&view=rev
Log:
cleanup

Removed:
    cassandra/trunk/src/java/org/apache/cassandra/db/MemtableAllocator.java
Modified:
    cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamily.java
    cassandra/trunk/src/java/org/apache/cassandra/db/marshal/IntegerType.java

Modified: cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamily.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamily.java?rev=1146569&r1=1146568&r2=1146569&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamily.java 
(original)
+++ cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamily.java Thu Jul 
14 05:49:37 2011
@@ -59,8 +59,6 @@ public class ColumnFamily extends Abstra
         return new ColumnFamily(cfm);
     }
 
-    private transient IColumnSerializer columnSerializer;
-    
     public ColumnFamily(CFMetaData cfm)
     {
         this(cfm, new ConcurrentSkipListMap<ByteBuffer, 
IColumn>(cfm.comparator));
@@ -71,7 +69,6 @@ public class ColumnFamily extends Abstra
         super(map);
         assert cfm != null;
         this.cfm = cfm;
-        columnSerializer = cfm.getColumnSerializer();
     }
     
     public ColumnFamily cloneMeShallow()
@@ -84,7 +81,8 @@ public class ColumnFamily extends Abstra
 
     public AbstractType getSubComparator()
     {
-        return (columnSerializer instanceof SuperColumnSerializer) ? 
((SuperColumnSerializer)columnSerializer).getComparator() : null;
+        IColumnSerializer s = getColumnSerializer();
+        return (s instanceof SuperColumnSerializer) ? ((SuperColumnSerializer) 
s).getComparator() : null;
     }
 
     public ColumnFamilyType getType()
@@ -115,7 +113,7 @@ public class ColumnFamily extends Abstra
 
     public IColumnSerializer getColumnSerializer()
     {
-        return columnSerializer;
+        return cfm.getColumnSerializer();
     }
 
     public boolean isSuper()

Modified: 
cassandra/trunk/src/java/org/apache/cassandra/db/marshal/IntegerType.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/db/marshal/IntegerType.java?rev=1146569&r1=1146568&r2=1146569&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/db/marshal/IntegerType.java 
(original)
+++ cassandra/trunk/src/java/org/apache/cassandra/db/marshal/IntegerType.java 
Thu Jul 14 05:49:37 2011
@@ -24,7 +24,6 @@ import java.nio.ByteBuffer;
 import java.sql.Types;
 
 import org.apache.cassandra.utils.ByteBufferUtil;
-import org.apache.thrift.TBaseHelper;
 
 public final class IntegerType extends AbstractType<BigInteger>
 {


Reply via email to