rows,columns -> partitions,cells

Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/84b47c89
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/84b47c89
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/84b47c89

Branch: refs/heads/trunk
Commit: 84b47c89a1520f41bdf2cb1e0da8ec18a1cbfd21
Parents: 579eb22
Author: Jonathan Ellis <jbel...@apache.org>
Authored: Fri Nov 1 19:43:08 2013 -0500
Committer: Jonathan Ellis <jbel...@apache.org>
Committed: Fri Nov 1 20:02:46 2013 -0500

----------------------------------------------------------------------
 src/java/org/apache/cassandra/db/Memtable.java                  | 2 +-
 src/java/org/apache/cassandra/db/compaction/CompactionTask.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/84b47c89/src/java/org/apache/cassandra/db/Memtable.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/Memtable.java 
b/src/java/org/apache/cassandra/db/Memtable.java
index 12d36bf..3bb8c1e 100644
--- a/src/java/org/apache/cassandra/db/Memtable.java
+++ b/src/java/org/apache/cassandra/db/Memtable.java
@@ -446,7 +446,7 @@ public class Memtable
                 else
                     cfs.liveRatio = (cfs.liveRatio + newRatio) / 2.0;
 
-                logger.info("{} liveRatio is {} (just-counted was {}).  
calculation took {}ms for {} columns",
+                logger.info("{} liveRatio is {} (just-counted was {}).  
calculation took {}ms for {} cells",
                             cfs, cfs.liveRatio, newRatio, 
TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start), objects);
             }
             finally

http://git-wip-us.apache.org/repos/asf/cassandra/blob/84b47c89/src/java/org/apache/cassandra/db/compaction/CompactionTask.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/compaction/CompactionTask.java 
b/src/java/org/apache/cassandra/db/compaction/CompactionTask.java
index cd7d3d9..6c6f852 100644
--- a/src/java/org/apache/cassandra/db/compaction/CompactionTask.java
+++ b/src/java/org/apache/cassandra/db/compaction/CompactionTask.java
@@ -272,7 +272,7 @@ public class CompactionTask extends AbstractCompactionTask
         }
 
         SystemKeyspace.updateCompactionHistory(cfs.keyspace.getName(), 
cfs.name, start, startsize, endsize, mergedRows);
-        logger.info(String.format("Compacted %d sstables to [%s].  %,d bytes 
to %,d (~%d%% of original) in %,dms = %fMB/s.  %,d total rows, %,d unique.  Row 
merge counts were {%s}",
+        logger.info(String.format("Compacted %d sstables to [%s].  %,d bytes 
to %,d (~%d%% of original) in %,dms = %fMB/s.  %,d total partitions merged to 
%,d.  Partition merge counts were {%s}",
                                   toCompact.size(), builder.toString(), 
startsize, endsize, (int) (ratio * 100), dTime, mbps, totalSourceRows, 
totalkeysWritten, mergeSummary.toString()));
         logger.debug(String.format("CF Total Bytes Compacted: %,d", 
CompactionTask.addToTotalBytesCompacted(endsize)));
     }

Reply via email to