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 <dbros...@mebigfatguy.com> Authored: Sun Jun 5 20:00:51 2016 -0400 Committer: Dave Brosius <dbros...@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()