log number of rows read from saved cache patch by Sankalp Kohli; reviewed by jbellis for CASSANDRA-4249
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/7dae25d8 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/7dae25d8 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/7dae25d8 Branch: refs/heads/cassandra-1.1 Commit: 7dae25d87e77208c471c59b1851981bf34acaafb Parents: 1e8685d Author: Jonathan Ellis <jbel...@apache.org> Authored: Wed May 16 11:08:05 2012 -0500 Committer: Jonathan Ellis <jbel...@apache.org> Committed: Wed May 16 11:08:05 2012 -0500 ---------------------------------------------------------------------- CHANGES.txt | 1 + .../org/apache/cassandra/db/ColumnFamilyStore.java | 1 + 2 files changed, 2 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/7dae25d8/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 4f1046b..d59480a 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 1.1.1-dev + * log number of rows read from saved cache (CASSANDRA-4249) * calculate exact size required for cleanup operations (CASSANDRA-1404) * avoid blocking additional writes during flush when the commitlog gets behind temporarily (CASSANDRA-1991) http://git-wip-us.apache.org/repos/asf/cassandra/blob/7dae25d8/src/java/org/apache/cassandra/db/ColumnFamilyStore.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/ColumnFamilyStore.java b/src/java/org/apache/cassandra/db/ColumnFamilyStore.java index 4cfe041..c55d924 100644 --- a/src/java/org/apache/cassandra/db/ColumnFamilyStore.java +++ b/src/java/org/apache/cassandra/db/ColumnFamilyStore.java @@ -418,6 +418,7 @@ public class ColumnFamilyStore implements ColumnFamilyStoreMBean Integer.MIN_VALUE, true); CacheService.instance.rowCache.put(new RowCacheKey(metadata.cfId, key), data); + cachedRowsRead++; } if (cachedRowsRead > 0)
