cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From marc...@apache.org
Subject cassandra git commit: Readd the per row compactionstats progress update
Date Thu, 01 Oct 2015 14:43:53 GMT
Repository: cassandra
Updated Branches:
  refs/heads/cassandra-3.0 750381598 -> a1b04c49e


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/cassandra-3.0
Commit: a1b04c49e6b5a4762344c0e5b8e04db839a75adc
Parents: 7503815
Author: Marcus Eriksson <marcuse@apache.org>
Authored: Thu Oct 1 16:43:13 2015 +0200
Committer: Marcus Eriksson <marcuse@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;
+            }
         };
     }
 };


Mime
View raw message