Readd the per row compactionstats progress update
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/a1b04c49 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/a1b04c49 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/a1b04c49 Branch: refs/heads/trunk Commit: a1b04c49e6b5a4762344c0e5b8e04db839a75adc Parents: 7503815 Author: Marcus Eriksson <marc...@apache.org> Authored: Thu Oct 1 16:43:13 2015 +0200 Committer: Marcus Eriksson <marc...@apache.org> Committed: Thu Oct 1 16:43:13 2015 +0200 ---------------------------------------------------------------------- .../cassandra/db/partitions/PurgingPartitionIterator.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/a1b04c49/src/java/org/apache/cassandra/db/partitions/PurgingPartitionIterator.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/partitions/PurgingPartitionIterator.java b/src/java/org/apache/cassandra/db/partitions/PurgingPartitionIterator.java index 5c7f6f4..d23d4a7 100644 --- a/src/java/org/apache/cassandra/db/partitions/PurgingPartitionIterator.java +++ b/src/java/org/apache/cassandra/db/partitions/PurgingPartitionIterator.java @@ -141,6 +141,14 @@ public abstract class PurgingPartitionIterator extends WrappingUnfilteredPartiti return purger.shouldPurge(((RangeTombstoneBoundMarker)marker).deletionTime()) ? null : marker; } } + + @Override + public Unfiltered next() + { + Unfiltered next = super.next(); + updateProgress(); + return next; + } }; } };
