diff --git a/src/org/apache/cassandra/db/ColumnFamily.java b/src/org/apache/cassandra/db/ColumnFamily.java index 8a205251db..96f0dcc535 100644 --- a/src/org/apache/cassandra/db/ColumnFamily.java +++ b/src/org/apache/cassandra/db/ColumnFamily.java @@ -70,7 +70,7 @@ public final class ColumnFamily implements Serializable * This method returns the serializer whose methods are * preprocessed by a dynamic proxy. */ - public static ICompactSerializer2 serializer2() + public static ICompactSerializer2 serializerWithIndexes() { return (ICompactSerializer2)Proxy.newProxyInstance( ColumnFamily.class.getClassLoader(), new Class[]{ICompactSerializer2.class}, new CompactSerializerInvocationHandler(serializer_) ); } diff --git a/src/org/apache/cassandra/db/ColumnFamilyStore.java b/src/org/apache/cassandra/db/ColumnFamilyStore.java index 8b7df4e7fc..326a524647 100644 --- a/src/org/apache/cassandra/db/ColumnFamilyStore.java +++ b/src/org/apache/cassandra/db/ColumnFamilyStore.java @@ -22,10 +22,7 @@ import java.io.*; import java.math.BigInteger; import java.util.*; import java.util.concurrent.ExecutionException; -import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; -import java.util.concurrent.LinkedBlockingQueue; -import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReference; @@ -38,16 +35,12 @@ import org.apache.cassandra.io.IndexHelper; import org.apache.cassandra.io.SSTable; import org.apache.cassandra.io.SequenceFile; import org.apache.cassandra.net.EndPoint; -import org.apache.cassandra.net.Message; -import org.apache.cassandra.net.MessagingService; import org.apache.cassandra.service.PartitionerType; import org.apache.cassandra.service.StorageService; import org.apache.cassandra.utils.BloomFilter; import org.apache.cassandra.utils.FileUtils; import org.apache.cassandra.utils.LogUtil; import org.apache.log4j.Logger; -import org.apache.cassandra.io.*; -import org.apache.cassandra.utils.*; /** * Author : Avinash Lakshman ( alakshman@facebook.com) & Prashant Malik ( pmalik@facebook.com ) @@ -1167,7 +1160,7 @@ public class ColumnFamilyStore if( columnFamily != null ) { /* serialize the cf with column indexes */ - ColumnFamily.serializer2().serialize(columnFamily, bufOut); + ColumnFamily.serializerWithIndexes().serialize(columnFamily, bufOut); } } else @@ -1417,7 +1410,7 @@ public class ColumnFamilyStore if( columnFamily != null ) { /* serialize the cf with column indexes */ - ColumnFamily.serializer2().serialize(columnFamily, bufOut); + ColumnFamily.serializerWithIndexes().serialize(columnFamily, bufOut); } } else diff --git a/src/org/apache/cassandra/db/Memtable.java b/src/org/apache/cassandra/db/Memtable.java index 27350f799e..945ad31466 100644 --- a/src/org/apache/cassandra/db/Memtable.java +++ b/src/org/apache/cassandra/db/Memtable.java @@ -36,14 +36,11 @@ import org.apache.cassandra.concurrent.ThreadFactoryImpl; import org.apache.cassandra.config.DatabaseDescriptor; import org.apache.cassandra.io.DataOutputBuffer; import org.apache.cassandra.io.SSTable; -import org.apache.cassandra.service.IComponentShutdown; import org.apache.cassandra.service.PartitionerType; import org.apache.cassandra.service.StorageService; import org.apache.cassandra.utils.BloomFilter; import org.apache.cassandra.utils.LogUtil; import org.apache.log4j.Logger; -import org.apache.cassandra.io.*; -import org.apache.cassandra.utils.*; /** * Author : Avinash Lakshman ( alakshman@facebook.com) & Prashant Malik ( pmalik@facebook.com ) @@ -480,7 +477,7 @@ public class Memtable implements MemtableMBean, Comparable if ( columnFamily != null ) { /* serialize the cf with column indexes */ - ColumnFamily.serializer2().serialize( columnFamily, buffer ); + ColumnFamily.serializerWithIndexes().serialize( columnFamily, buffer ); /* Now write the key and value to disk */ ssTable.append(pKey.key(), pKey.hash(), buffer); bf.fill(pKey.key()); @@ -507,7 +504,7 @@ public class Memtable implements MemtableMBean, Comparable if ( columnFamily != null ) { /* serialize the cf with column indexes */ - ColumnFamily.serializer2().serialize( columnFamily, buffer ); + ColumnFamily.serializerWithIndexes().serialize( columnFamily, buffer ); /* Now write the key and value to disk */ ssTable.append(key, buffer); bf.fill(key); diff --git a/src/org/apache/cassandra/test/SSTableTest.java b/src/org/apache/cassandra/test/SSTableTest.java index 451c19953e..c877cbef6e 100644 --- a/src/org/apache/cassandra/test/SSTableTest.java +++ b/src/org/apache/cassandra/test/SSTableTest.java @@ -26,7 +26,6 @@ import java.util.List; import java.util.Map; import java.util.Random; -import org.apache.cassandra.config.DatabaseDescriptor; import org.apache.cassandra.db.ColumnFamily; import org.apache.cassandra.db.IColumn; import org.apache.cassandra.db.PrimaryKey; @@ -35,7 +34,6 @@ import org.apache.cassandra.io.DataOutputBuffer; import org.apache.cassandra.io.SSTable; import org.apache.cassandra.service.PartitionerType; import org.apache.cassandra.utils.BloomFilter; -import org.apache.cassandra.utils.FBUtilities; public class SSTableTest @@ -54,7 +52,7 @@ public class SSTableTest bufOut.reset(); // random.nextBytes(bytes); cf.createColumn("C", "Avinash Lakshman is a good man".getBytes(), i); - ColumnFamily.serializer2().serialize(cf, bufOut); + ColumnFamily.serializerWithIndexes().serialize(cf, bufOut); ssTable.append(key, bufOut); bf.fill(key); } @@ -92,7 +90,7 @@ public class SSTableTest if ( columnFamily != null ) { /* serialize the cf with column indexes */ - ColumnFamily.serializer2().serialize( columnFamily, buffer ); + ColumnFamily.serializerWithIndexes().serialize( columnFamily, buffer ); /* Now write the key and value to disk */ ssTable.append(pKey.key(), pKey.hash(), buffer); bf.fill(pKey.key());