Updated Branches: refs/heads/trunk 45b057bcf -> d2b60f289
use proper partitioner for Range; patch by yukim, reviewed by jbellis for CASSANDRA-4404 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/d2b60f28 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/d2b60f28 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/d2b60f28 Branch: refs/heads/trunk Commit: d2b60f28935466f6e37fc9d64a44c5c81bc14fb4 Parents: 45b057b Author: Yuki Morishita <yu...@apache.org> Authored: Tue Jul 3 12:44:14 2012 -0500 Committer: Yuki Morishita <yu...@apache.org> Committed: Tue Jul 3 12:44:14 2012 -0500 ---------------------------------------------------------------------- .../compaction/SizeTieredCompactionStrategy.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/d2b60f28/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java b/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java index 9c07a93..67d2e77 100644 --- a/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java +++ b/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java @@ -107,7 +107,7 @@ public class SizeTieredCompactionStrategy extends AbstractCompactionStrategy long keys = table.estimatedKeys(); Set<Range<Token>> ranges = new HashSet<Range<Token>>(); for (SSTableReader overlap : overlaps) - ranges.add(new Range<Token>(overlap.first.token, overlap.last.token)); + ranges.add(new Range<Token>(overlap.first.token, overlap.last.token, overlap.partitioner)); long remainingKeys = keys - table.estimatedKeysForRanges(ranges); // next, calculate what percentage of columns we have within those keys double remainingKeysRatio = ((double) remainingKeys) / keys;