You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by db...@apache.org on 2016/06/06 00:01:50 UTC
cassandra git commit: push down (delay) allocations to where they are
needed
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 <db...@mebigfatguy.com>
Authored: Sun Jun 5 20:00:51 2016 -0400
Committer: Dave Brosius <db...@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()