svn commit: r915563 - /incubator/cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/db/CompactionManager.java

[jbellis]

Author: jbellis
Date: Tue Feb 23 22:40:57 2010
New Revision: 915563

URL: http://svn.apache.org/viewvc?rev=915563&view=rev
Log:
rename CM.getCompactionBuckets -> CM.getBuckets.  patch by jbellis

Modified:
    
incubator/cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/db/CompactionManager.java

Modified: 
incubator/cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/db/CompactionManager.java
URL: 
http://svn.apache.org/viewvc/incubator/cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/db/CompactionManager.java?rev=915563&r1=915562&r2=915563&view=diff
==============================================================================
--- 
incubator/cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/db/CompactionManager.java
 (original)
+++ 
incubator/cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/db/CompactionManager.java
 Tue Feb 23 22:40:57 2010
@@ -89,7 +89,7 @@
                     return 0;
                 }
                 logger.debug("Checking to see if compaction of " + 
cfs.columnFamily_ + " would be useful");
-                Set<List<SSTableReader>> buckets = 
getCompactionBuckets(cfs.getSSTables(), 50L * 1024L * 1024L);
+                Set<List<SSTableReader>> buckets = 
getBuckets(cfs.getSSTables(), 50L * 1024L * 1024L);
                 updateEstimateFor(cfs, buckets);
                 
                 for (List<SSTableReader> sstables : buckets)
@@ -446,7 +446,7 @@
     /*
     * Group files of similar size into buckets.
     */
-    static Set<List<SSTableReader>> 
getCompactionBuckets(Iterable<SSTableReader> files, long min)
+    static Set<List<SSTableReader>> getBuckets(Iterable<SSTableReader> files, 
long min)
     {
         Map<List<SSTableReader>, Long> buckets = new 
HashMap<List<SSTableReader>, Long>();
         for (SSTableReader sstable : files)
@@ -543,7 +543,7 @@
                 public void run ()
                 {
                     logger.debug("Estimating compactions for " + 
cfs.columnFamily_);
-                    final Set<List<SSTableReader>> buckets = 
getCompactionBuckets(cfs.getSSTables(), 50L * 1024L * 1024L);
+                    final Set<List<SSTableReader>> buckets = 
getBuckets(cfs.getSSTables(), 50L * 1024L * 1024L);
                     updateEstimateFor(cfs, buckets);
                 }
             };