cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dbros...@apache.org
Subject cassandra git commit: push down (delay) allocations to where they are needed
Date Mon, 06 Jun 2016 00:01:50 GMT
Repository: cassandra
Updated Branches:
  refs/heads/trunk a07db4945 -> 60eed6346


push down (delay) allocations to where they are needed


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

Branch: refs/heads/trunk
Commit: 60eed63462f90dfd58b61fb333971595142c3d60
Parents: a07db49
Author: Dave Brosius <dbrosius@mebigfatguy.com>
Authored: Sun Jun 5 20:00:51 2016 -0400
Committer: Dave Brosius <dbrosius@mebigfatguy.com>
Committed: Sun Jun 5 20:01:28 2016 -0400

----------------------------------------------------------------------
 src/java/org/apache/cassandra/db/view/ViewBuilder.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/60eed634/src/java/org/apache/cassandra/db/view/ViewBuilder.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/view/ViewBuilder.java b/src/java/org/apache/cassandra/db/view/ViewBuilder.java
index 65e26e2..956c064 100644
--- a/src/java/org/apache/cassandra/db/view/ViewBuilder.java
+++ b/src/java/org/apache/cassandra/db/view/ViewBuilder.java
@@ -72,7 +72,6 @@ public class ViewBuilder extends CompactionInfo.Holder
 
     private void buildKey(DecoratedKey key)
     {
-        AtomicLong noBase = new AtomicLong(Long.MAX_VALUE);
         ReadQuery selectQuery = view.getReadQuery();
         if (!selectQuery.selectsKey(key))
             return;
@@ -92,7 +91,10 @@ public class ViewBuilder extends CompactionInfo.Holder
         }
 
         if (!mutations.isEmpty())
+        {
+            AtomicLong noBase = new AtomicLong(Long.MAX_VALUE);
             StorageProxy.mutateMV(key.getKey(), mutations, true, noBase);
+        }
     }
 
     public void run()


Mime
View raw message