Author: jbellis Date: Wed May 18 17:56:14 2011 New Revision: 1124355 URL: http://svn.apache.org/viewvc?rev=1124355&view=rev Log: r/m unused code
Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/CompactionManager.java Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/CompactionManager.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/CompactionManager.java?rev=1124355&r1=1124354&r2=1124355&view=diff ============================================================================== --- cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/CompactionManager.java (original) +++ cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/CompactionManager.java Wed May 18 17:56:14 2011 @@ -1169,31 +1169,6 @@ public class CompactionManager implement } } - public void checkAllColumnFamilies() throws IOException - { - // perform estimates - for (final ColumnFamilyStore cfs : ColumnFamilyStore.all()) - { - Runnable runnable = new Runnable() - { - public void run () - { - logger.debug("Estimating compactions for " + cfs.columnFamily); - final Set<List<SSTableReader>> buckets = getBuckets(convertSSTablesToPairs(cfs.getSSTables()), 50L * 1024L * 1024L); - updateEstimateFor(cfs, buckets); - } - }; - executor.submit(runnable); - } - - // actually schedule compactions. done in a second pass so all the estimates occur before we - // bog down the executor in actual compactions. - for (ColumnFamilyStore cfs : ColumnFamilyStore.all()) - { - submitMinorIfNeeded(cfs); - } - } - public int getActiveCompactions() { return executor.getActiveCount();