Author: jbellis
Date: Mon Jul  5 20:54:51 2010
New Revision: 960694

URL: http://svn.apache.org/viewvc?rev=960694&view=rev
Log:
r/m unused code.  patch by jbellis

Modified:
    cassandra/trunk/src/java/org/apache/cassandra/db/Table.java
    cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java

Modified: cassandra/trunk/src/java/org/apache/cassandra/db/Table.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/db/Table.java?rev=960694&r1=960693&r2=960694&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/db/Table.java (original)
+++ cassandra/trunk/src/java/org/apache/cassandra/db/Table.java Mon Jul  5 
20:54:51 2010
@@ -58,7 +58,6 @@ public class Table 
     static final ReentrantReadWriteLock flusherLock = new 
ReentrantReadWriteLock(true);
 
     private static Timer flushTimer = new Timer("FLUSH-TIMER");
-    private final boolean waitForCommitLog;
 
     // This is a result of pushing down the point in time when storage 
directories get created.  It used to happen in
     // CassandraDaemon, but it is possible to call Table.open without a 
running daemon, so it made sense to ensure
@@ -216,7 +215,6 @@ public class Table 
     private Table(String table)
     {
         name = table;
-        waitForCommitLog = DatabaseDescriptor.getCommitLogSync() == 
Config.CommitLogSync.batch;
         // create data directories.
         for (String dataDir : DatabaseDescriptor.getAllDataFileLocations())
         {

Modified: 
cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java?rev=960694&r1=960693&r2=960694&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java 
(original)
+++ cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java 
Mon Jul  5 20:54:51 2010
@@ -1687,7 +1687,6 @@ public class StorageService implements I
         return old;
     }
 
-    @Override
     public void truncate(String keyspace, String columnFamily) throws 
UnavailableException, TimeoutException, IOException
     {
         StorageProxy.truncateBlocking(keyspace, columnFamily);


Reply via email to